WorkflowStore
Defined in: packages/core/src/observability/workflow-store.ts:30
Workflow run persistence: materialized run/step I/O plus append-only RunEvents.
Observers (WorkflowObserver) are push-only — no reads. WorkflowStore supports
queries (listRuns, listEvents, getStepOutput) for UI and step skip on retry.
RunRecorder writes to both when configured. Separate from MessageStore.
Default implementation: inMemoryWorkflowStore.
Methods
Section titled “Methods”getLatestEvent()
Section titled “getLatestEvent()”getLatestEvent<
T>(scope,type):Promise<RunEventOfType<T> |null>
Defined in: packages/core/src/observability/workflow-store.ts:40
Type Parameters
Section titled “Type Parameters”T extends "workflow_started" | "workflow_finished" | "workflow_failed" | "workflow_cancelled" | "step_started" | "step_finished" | "step_skipped" | "step_failed" | "custom" | "agent_started" | "agent_finished" | "agent_failed" | "agent_tool_call" | "agent_tool_result" | "agent_text_delta" | "agent_messages_committed"
Parameters
Section titled “Parameters”T
Returns
Section titled “Returns”Promise<RunEventOfType<T> | null>
getRun()
Section titled “getRun()”getRun(
workflowRunId):Promise<WorkflowRunSummary|null>
Defined in: packages/core/src/observability/workflow-store.ts:45
Parameters
Section titled “Parameters”workflowRunId
Section titled “workflowRunId”string
Returns
Section titled “Returns”Promise<WorkflowRunSummary | null>
getRunInput()
Section titled “getRunInput()”getRunInput(
workflowRunId):Promise<unknown>
Defined in: packages/core/src/observability/workflow-store.ts:47
Parameters
Section titled “Parameters”workflowRunId
Section titled “workflowRunId”string
Returns
Section titled “Returns”Promise<unknown>
getRunOutput()
Section titled “getRunOutput()”getRunOutput(
workflowRunId):Promise<unknown>
Defined in: packages/core/src/observability/workflow-store.ts:48
Parameters
Section titled “Parameters”workflowRunId
Section titled “workflowRunId”string
Returns
Section titled “Returns”Promise<unknown>
getStepById()
Section titled “getStepById()”getStepById(
workflowRunId,stepId):Promise<StepRecord|null>
Defined in: packages/core/src/observability/workflow-store.ts:50
Parameters
Section titled “Parameters”workflowRunId
Section titled “workflowRunId”string
stepId
Section titled “stepId”string
Returns
Section titled “Returns”Promise<StepRecord | null>
getStepOutput()
Section titled “getStepOutput()”getStepOutput(
workflowRunId,slot):Promise<unknown>
Defined in: packages/core/src/observability/workflow-store.ts:49
Parameters
Section titled “Parameters”workflowRunId
Section titled “workflowRunId”string
Returns
Section titled “Returns”Promise<unknown>
listEvents()
Section titled “listEvents()”listEvents(
scope,filter?):Promise<RunEvent[]>
Defined in: packages/core/src/observability/workflow-store.ts:38
Read events for a workflow run or a standalone agent episode.
Workflow-scoped queries return workflow + step + custom events for that workflowRunId.
Agent-scoped queries return agent events for that agentCallId.
Parameters
Section titled “Parameters”filter?
Section titled “filter?”Returns
Section titled “Returns”Promise<RunEvent[]>
listRuns()
Section titled “listRuns()”listRuns(
filter?):Promise<WorkflowRunSummary[]>
Defined in: packages/core/src/observability/workflow-store.ts:46
Parameters
Section titled “Parameters”filter?
Section titled “filter?”limit?
Section titled “limit?”number
workflowId?
Section titled “workflowId?”string
Returns
Section titled “Returns”Promise<WorkflowRunSummary[]>
recordEvent()
Section titled “recordEvent()”recordEvent(
event):Promise<void>
Defined in: packages/core/src/observability/workflow-store.ts:31
Parameters
Section titled “Parameters”Returns
Section titled “Returns”Promise<void>