riotpiao-poimen/homelab-frontend
2
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add SSE streaming endpoint for workflow events #36

Merged
rock merged 1 commits from feat/sse-workflow-stream into main 2026-09-26 10:50:19 +00:00
Conversation 0 Commits 1 Files Changed 3
+239
rock commented 2026-09-26 10:14:25 +00:00
Owner
Copy Link
Copy Source

New SSE endpoint: GET /workflow/stream?workflow_id=X&namespace=default

  • Polls Temporal GetWorkflowExecutionHistory every 2s
  • Maps event types to semantic SSE events (activity_started/completed/failed, workflow_completed, etc.)
  • Heartbeat every 15s
  • Clean close on workflow completion or client disconnect
  • Added stream resource to workflow ServiceAdapter spec

Closes #33

New SSE endpoint: GET /workflow/stream?workflow_id=X&namespace=default - Polls Temporal GetWorkflowExecutionHistory every 2s - Maps event types to semantic SSE events (activity_started/completed/failed, workflow_completed, etc.) - Heartbeat every 15s - Clean close on workflow completion or client disconnect - Added stream resource to workflow ServiceAdapter spec Closes #33
rock added 1 commit 2026-09-26 10:14:26 +00:00
feat: add SSE streaming endpoint for workflow events (#33)
CI / CI (pull_request) Canceled after 14s
Details
f280415060 
- New internal/temporal/sse.go: StreamWorkflowEvents handler
- Polls Temporal GetWorkflowExecutionHistory every 2s
- Maps Temporal event types to semantic SSE events
  (activity_started/completed/failed, workflow_completed, etc.)
- Heartbeat every 15s, clean close on workflow completion
- Route: GET /workflow/stream?workflow_id=X&namespace=default
- Added stream resource to workflow ServiceAdapter spec

Closes #33
rock merged commit 6b089ff223 into main 2026-09-26 10:50:19 +00:00
rock deleted branch feat/sse-workflow-stream 2026-09-26 10:50:20 +00:00
Sign in to join this conversation.
Reviewers
No Reviewers
Labels
Clear labels
area/auth
Authentication & authorization
 area/authentik
Authentik OIDC provider config
 area/downstream
Downstream service changes
 area/gateway
API gateway code
 priority/high
Must have
 priority/low
Nice to have
 priority/medium
Should have
 status/blocked
Blocked by dependency
 status/done
Completed
 status/in-progress
Currently being worked on
 status/review
Ready for review
 status/todo
Not started
 type/docs
Documentation
 type/feature
New feature
 type/infra
Infrastructure change
No labels
Milestone
No items
No Milestone
Projects
Clear projects
No projects
Assignees
Clear assignees
poimen rock (Rock)
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: riotpiao-poimen/homelab-frontend#36