Run.observeStream()

그만큼.observeStream()메서드가 새 항목을 엽니다.ReadableStream현재 실행 중인 Workflow 실행에 추가하여 원래 스트림을 더 이상 사용할 수 없는 경우 이벤트 스트림을 관찰할 수 있습니다.

사용예

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의 최종 결과가 담깁니다.

관련된

• Workflow 개요
• Workflow.createRun()
• 실행.스트림()
• 실행.이력스트림()