Function runWorkflow

src/cli/workflow.ts:397–462

(scriptPath: string, options: WorkflowCLIOptions)

}

async function runWorkflow(scriptPath: string, options: WorkflowCLIOptions): Promise<number> {
  const projectDir = await resolveProjectDir({
    cwd: process.cwd(),
    explicitDir: options.dir,
  });
  parseRuntimeConfig(options.runtime);

  const args = await parseWorkflowArgs({
    arg: options.arg,
    argsJson: options.argsJson,
    argsFile: options.argsFile,
    argsStdin: options.argsStdin,
  });
  const model = resolveModelAlias(options.model);
  const thinkingLevel = resolveThinkingInput(parseThinkingLevel(options.thinking), model);
  const suppressHuman = options.json === true || options.quiet === true;
  const writeLine = (line = "") => {
    if (!suppressHuman) process.stdout.write(`${line}\n`);
  };

  const ctx = await createWorkflowContext({ opts: options, projectDir });
  try {
    const workflowService = createWorkflowService({ ctx, opts: options, model, thinkingLevel });
    writeLine(`workflow: ${scriptPath}`);
    writeLine(`directory: ${projectDir}`);
    writeLine(`runtime: ${ctx.runtimeConfig.type}`);

    const runtime = createRuntime(ctx.runtimeConfig, {
      projectPath: ctx.projectDir,
      workspaceName: ctx.workspaceId,
      workspacePath: ctx.workspacePath,
    });
    const script = await resolveWorkflowScript({
      scriptPath,
      runtime,
      workspacePath: ctx.workspacePath,
      projectTrusted: ctx.projectTrusted,
    });
    const result = await workflowService.startWorkflow({
      script,
      workspaceId: ctx.workspaceId,
      projectTrusted: ctx.projectTrusted,
      args,
      backgroundOnMessageQueued: false,
    });
    if (result.status === "backgrounded") {
      throw new Error("Headless workflow runs must finish in the foreground");
    }
    const run = await workflowService.getRun({ workspaceId: ctx.workspaceId, runId: result.runId });
    if (options.json === true) {
      process.stdout.write(
        `${JSON.stringify({ type: "result", runId: result.runId, status: run?.status ?? result.status, result: result.result })}\n`
      );
    } else {
      const reportMarkdown = extractReportMarkdown(result.result);
      if (reportMarkdown.length > 0) {
        process.stdout.write(reportMarkdown);
        if (!reportMarkdown.endsWith("\n")) process.stdout.write("\n");