Skip to Content

Run Class

The Run class represents a workflow execution instance, providing methods to start, resume, stream, and monitor workflow execution.

Usage example

const run = await workflow.createRunAsync(); const result = await run.start({ inputData: { value: "initial data" } }); if (result.status === "suspended") { const resumedResult = await run.resume({ resumeData: { value: "resume data" } }); }

Run Methods

start:

(options?: StartOptions) => Promise<WorkflowResult>
Starts workflow execution with input data

resume:

(options?: ResumeOptions) => Promise<WorkflowResult>
Resumes a suspended workflow from a specific step

stream:

(options?: StreamOptions) => Promise<StreamResult>
Monitors workflow execution as a stream of events

streamVNext:

(options?: StreamOptions) => MastraWorkflowStream
Enables real-time streaming with enhanced features

watch:

(callback: WatchCallback, type?: WatchType) => UnwatchFunction
Monitors workflow execution with callback-based events

cancel:

() => Promise<void>
Cancels the workflow execution

Run Status

A workflow run’s status indicates its current execution state. The possible values are:

success:

string
All steps finished executing successfully, with a valid result output

failed:

string
Workflow execution encountered an error during execution, with error details available

suspended:

string
Workflow execution is paused waiting for resume, with suspended step information