Run.observeStreamVNext() (Experimental)
The .observeStreamVNext() method opens a new ReadableStream to a workflow run that is currently running, allowing you to observe the stream of events if the original stream is no longer available.
Usage example
const run = await workflow.createRunAsync();
run.streamVNext({
inputData: {
value: "initial data",
},
});
const stream = await run.observeStreamVNext();
for await (const chunk of stream) {
console.log(chunk);
}Returns
ReadableStream<ChunkType>
Stream Events
The stream emits various event types during workflow execution. Each event has a type field and a payload containing relevant data:
workflow-start: Workflow execution beginsworkflow-step-start: A step begins executionworkflow-step-output: Custom output from a stepworkflow-step-result: A step completes with resultsworkflow-finish: Workflow execution completes with usage statistics