Run.observeStream()
.observeStream() 方法會為目前正在執行的 Workflow 開啟新的 ReadableStream。若原始串流已無法使用,你仍可透過這個新串流觀察事件。
使用範例「使用範例」的直接連結
const run = await workflow.createRun()
run.stream({
inputData: {
value: 'initial data',
},
})
const stream = await run.observeStream()
for await (const chunk of stream) {
console.log(chunk)
}
回傳值「回傳值」的直接連結
ReadableStream<ChunkType>
串流事件「串流事件」的直接連結
串流會在 Workflow 執行期間輸出各種事件類型。每個事件都有 type 欄位,以及包含相關資料的 payload:
workflow-start:Workflow 開始執行workflow-step-start:步驟開始執行workflow-step-output:步驟的自訂輸出workflow-step-result:步驟執行完成並產生結果workflow-finish:Workflow 執行完成,並提供用量統計資料。若執行成功,payload.finalWorkflowResult會包含 Workflow 的最終結果