Function main

scripts/capture-run-stream.ts:112–121

()

}

async function main() {
  console.log(
    `Starting workflow ${WORKFLOW_ID} via ${API_BASE_URL}/api/v1/workflows/${WORKFLOW_ID}/run`,
  )
  const { runId } = await startRun()
  console.log(`Run started: ${runId}`)
  console.log(`Subscribing to SSE stream and writing to ${OUTPUT_PATH} ...`)
  const path = await captureStream(runId, OUTPUT_PATH)
  console.log(`Stream capture completed: ${path}`)
}

main().catch((error) => {
  console.error('Failed to capture run stream', error)