Add SSE streaming endpoint for workflow events #33

New Issue

2026-09-26T09:47:51Z

rock commented

2026-09-26 09:47:51 +00:00

Description

Add Server-Sent Events endpoint to stream Temporal workflow execution events to the frontend in real-time.

Endpoint

GET /v1/poimen/executions/:id/stream
Authorization: Bearer <JWT>
Accept: text/event-stream

SSE Event Format

event: activity_started
data: {"node_id": "clone", "activity": "CloneRepoActivity", "timestamp": "..."}

event: activity_completed
data: {"node_id": "clone", "activity": "CloneRepoActivity", "output": {}, "duration_ms": 2500}

event: activity_failed
data: {"node_id": "scan", "activity": "SecurityScan", "error": "timeout", "attempt": 2}

event: workflow_completed
data: {"status": "COMPLETED", "final_output": {}}

event: heartbeat
data: {"timestamp": "..."}

Implementation

Long-lived HTTP connection with Content-Type: text/event-stream
Poll Temporal GetWorkflowExecutionHistory every 2s
Track last seen event_id, only send new events
Send heartbeat every 15s to keep connection alive
Close stream on workflow completion or client disconnect
Respect JWT expiry — close stream if token expires
Map Temporal history event types to semantic SSE events:
- ActivityTaskStarted → activity_started
- ActivityTaskCompleted → activity_completed
- ActivityTaskFailed → activity_failed
- WorkflowExecutionCompleted → workflow_completed

Acceptance Criteria

SSE stream opens and receives events in real-time
Events map to Temporal history event types
Stream closes cleanly on workflow completion
Heartbeat keeps connection alive
JWT validation on connection open

## Description Add Server-Sent Events endpoint to stream Temporal workflow execution events to the frontend in real-time. ## Endpoint ``` GET /v1/poimen/executions/:id/stream Authorization: Bearer <JWT> Accept: text/event-stream ``` ## SSE Event Format ``` event: activity_started data: {"node_id": "clone", "activity": "CloneRepoActivity", "timestamp": "..."} event: activity_completed data: {"node_id": "clone", "activity": "CloneRepoActivity", "output": {}, "duration_ms": 2500} event: activity_failed data: {"node_id": "scan", "activity": "SecurityScan", "error": "timeout", "attempt": 2} event: workflow_completed data: {"status": "COMPLETED", "final_output": {}} event: heartbeat data: {"timestamp": "..."} ``` ## Implementation - Long-lived HTTP connection with `Content-Type: text/event-stream` - Poll Temporal `GetWorkflowExecutionHistory` every 2s - Track last seen `event_id`, only send new events - Send `heartbeat` every 15s to keep connection alive - Close stream on workflow completion or client disconnect - Respect JWT expiry — close stream if token expires - Map Temporal history event types to semantic SSE events: - `ActivityTaskStarted` → `activity_started` - `ActivityTaskCompleted` → `activity_completed` - `ActivityTaskFailed` → `activity_failed` - `WorkflowExecutionCompleted` → `workflow_completed` ## Acceptance Criteria - [ ] SSE stream opens and receives events in real-time - [ ] Events map to Temporal history event types - [ ] Stream closes cleanly on workflow completion - [ ] Heartbeat keeps connection alive - [ ] JWT validation on connection open

rock referenced this issue from a commit

2026-09-26 10:14:13 +00:00

feat: add SSE streaming endpoint for workflow events (#33)

rock referenced a pull request that will close this issue

2026-09-26 10:14:25 +00:00

feat: add SSE streaming endpoint for workflow events #36

rock referenced this issue from a commit

2026-09-26 10:49:27 +00:00

feat: add SSE streaming endpoint for workflow events (#33)

rock referenced a pull request that will close this issue

2026-09-26 10:49:43 +00:00

feat: Poimen AI orchestrator API (Stream A: #31, #32, #33, #34) #37