Method writeRunFile

src/node/services/workflows/WorkflowRunStore.ts:1000–1007

(runId: string, run: WorkflowRunRecord)

  }

  private async writeRunFile(runId: string, run: WorkflowRunRecord): Promise<void> {
    const runForDisk = WorkflowRunRecordSchema.parse(run);
    await writeJsonAtomic(this.runFile(runId), runForDisk);
    // Notify live subscribers (workflows.subscribe) after the durable write. The hub is a
    // module-level bus, so any store instance — regardless of which flow constructed it —
    // feeds the same stream. Persist-before-notify keeps disk and observers consistent.
    workflowRunStreamHub.notifyRunPersisted(runForDisk);
  }

  getStepArtifactsDir(runId: string, stepId: string, inputHash: string): string {
    assertValidWorkflowRunId(runId);