MCPcopy Create free account
hub / github.com/ShipSecAI/studio / run

Method run

backend/src/workflows/workflows.service.ts:734–756  ·  view source on GitHub ↗
(
    id: string,
    request: WorkflowRunRequest = {},
    auth?: AuthContext | null,
    options: {
      trigger?: ExecutionTriggerMetadata;
      nodeOverrides?: Record<
        string,
        { params?: Record<string, unknown>; inputOverrides?: Record<string, unknown> }
      >;
      runId?: string;
      idempotencyKey?: string;
    } = {},
  )

Source from the content-addressed store, hash-verified

732 }
733
734 async run(
735 id: string,
736 request: WorkflowRunRequest = {},
737 auth?: AuthContext | null,
738 options: {
739 trigger?: ExecutionTriggerMetadata;
740 nodeOverrides?: Record<
741 string,
742 { params?: Record<string, unknown>; inputOverrides?: Record<string, unknown> }
743 >;
744 runId?: string;
745 idempotencyKey?: string;
746 } = {},
747 ): Promise<WorkflowRunHandle> {
748 const prepared = await this.prepareRunPayload(id, request, auth, {
749 trigger: options.trigger,
750 nodeOverrides: options.nodeOverrides,
751 runId: options.runId,
752 idempotencyKey: options.idempotencyKey,
753 });
754
755 return this.startPreparedRun(prepared);
756 }
757
758 async startPreparedRun(prepared: PreparedRunPayload): Promise<WorkflowRunHandle> {
759 const inputSummary = this.formatInputSummary(prepared.inputs);

Callers 9

connectToKafkaMethod · 0.45
connectToKafkaMethod · 0.45
onModuleInitMethod · 0.45
connectToKafkaMethod · 0.45
connectToKafkaMethod · 0.45
registerWorkflowToolsMethod · 0.45
mainFunction · 0.45

Calls 2

prepareRunPayloadMethod · 0.95
startPreparedRunMethod · 0.95

Tested by

no test coverage detected