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