mirror of
https://github.com/langflow-ai/langflow.git
synced 2026-07-23 17:31:33 +08:00
f86119b7d0
Advertises the streaming capability on both the handler card (the SDK's @validate gate) and the discovery card, which mounts message/stream and tasks/resubscribe through the existing dispatcher. message/stream replays the run lifecycle (submitted -> working -> artifact -> completed) as SSE frames by re-emitting the same executor events; tasks/resubscribe re-attaches to a live run and returns a spec error for terminal/cross-worker tasks (tasks/get covers terminal reads). Per-token deltas and durable cross-worker re-attach are follow-ups. Tests cover the advertised capability, the SSE lifecycle, and that resubscribe to a finished task ends with an error frame rather than hanging.