Method createRun

src/node/services/workflows/WorkflowRunStore.ts:104–135

(input: CreateWorkflowRunInput)

  }

  async createRun(input: CreateWorkflowRunInput): Promise<WorkflowRunRecord> {
    assert(input.id.length > 0, "WorkflowRunStore.createRun: id is required");
    assert(input.workspaceId.length > 0, "WorkflowRunStore.createRun: workspaceId is required");
    assert(input.source.length > 0, "WorkflowRunStore.createRun: source is required");

    const runDir = this.runDir(input.id);
    await fs.mkdir(runDir, { recursive: true });
    await fs.writeFile(path.join(runDir, WORKFLOW_SOURCE_FILENAME), input.source, "utf-8");
    await fs.writeFile(path.join(runDir, "events.jsonl"), "", { flag: "a" });
    await fs.writeFile(path.join(runDir, "steps.jsonl"), "", { flag: "a" });

    const run = WorkflowRunRecordSchema.parse({
      id: input.id,
      workspaceId: input.workspaceId,
      workflow: input.workflow,
      source: input.source,
      sourceHash: hashSource(input.source),
      args: input.args,
      agentOutputSchemaRequired: input.agentOutputSchemaRequired ?? true,
      agentTypeAliasAllowed: input.agentTypeAliasAllowed ?? false,
      ...(input.parentWorkflow != null ? { parentWorkflow: input.parentWorkflow } : {}),
      ...(input.attentionPolicy != null ? { attentionPolicy: input.attentionPolicy } : {}),
      status: "pending",
      createdAt: input.now,
      updatedAt: input.now,
      events: [],
      steps: [],
    });

    await this.writeRunFile(input.id, run);
    return run;
  }

  async createRunIfAbsent(input: CreateWorkflowRunInput): Promise<WorkflowRunRecord> {
    assert(input.id.length > 0, "WorkflowRunStore.createRunIfAbsent: id is required");