Run.watch()
.watch() メソッドを使うと、ワークフロー実行の進行状況を監視し、各ステップの状態に関する更新をリアルタイムで受け取れます。
使い方の例
const run = await workflow.createRunAsync();
run.watch((event) => {
console.log(event?.payload?.currentStep?.id);
});
const result = await run.start({ inputData: { value: "initial data" } });パラメータ
callback:
(event: WatchEvent) => void
ステップの完了時やワークフローの状態が変化したときに呼び出されるコールバック関数。event パラメータには、type（'watch'）、payload（currentStep と workflowState）、eventTimestamp が含まれます。
type?:
'watch' | 'watch-v2'
= 'watch'
受信する watch イベントの種類。ステップ完了イベントには 'watch'、データストリームイベントには 'watch-v2' を指定します。
戻り値
unwatch:
() => void
ワークフロー実行の監視を停止するために呼び出せる関数
拡張された使用例
const run = await workflow.createRunAsync();
run.watch((event) => {
console.log(event?.payload?.currentStep?.id);
}, "watch");
const result = await run.start({ inputData: { value: "initial data" } });