Method createWorkflowRun

src/node/services/workflows/WorkflowService.ts:683–703

(input: StartWorkflowInput)

  }

  private async createWorkflowRun(input: StartWorkflowInput): Promise<WorkflowRunRecord> {
    assert(
      input.workspaceId.length > 0,
      "WorkflowService.createWorkflowRun: workspaceId is required"
    );
    const runId = this.generateRunId();
    assert(runId.length > 0, "WorkflowService.createWorkflowRun: generated run id is required");

    const normalized = normalizeWorkflowArgsForSource(input.script.source, input.args, {
      defaultArgs: input.defaultArgs,
    });
    return await this.runStore.createRun({
      id: runId,
      workspaceId: input.workspaceId,
      workflow: buildWorkflowScriptDescriptor(input.script),
      source: input.script.source,
      args: normalized.args,
      ...(input.attentionPolicy != null ? { attentionPolicy: input.attentionPolicy } : {}),
      now: this.clock?.nowIso() ?? new Date().toISOString(),
    });
  }

  private async runInBackground(
    runId: string,