QuantumGhost eef13853b2 fix(api): StreamsBroadcastChannel start reading messages from the end (#34030) ... The current frontend implementation closes the connection once `workflow_paused` SSE event is received and establish a new connection to subscribe new events. The implementation of `StreamsBroadcastChannel` sets initial `_last_id` to `0-0`, consumes streams from start and send `workflow_paused` event created before pauses to frontend, causing excessive connections being established. This PR fixes the issue by setting initial id to `$`, which means only new messages are received by the subscription.		2026-03-25 10:21:57 +08:00
..
fixtures/workflow	fix(api): defer streaming response until referenced variables are updated (#30832)	2026-01-12 16:23:18 +08:00
integration_tests	test: unit test cases for sub modules in core.app (except core.app.apps) (#32476)	2026-03-25 02:13:28 +08:00
test_containers_integration_tests	fix(api): StreamsBroadcastChannel start reading messages from the end (#34030)	2026-03-25 10:21:57 +08:00
unit_tests	fix(api): StreamsBroadcastChannel start reading messages from the end (#34030)	2026-03-25 10:21:57 +08:00
__init__.py	Initial commit	2023-05-15 08:51:32 +08:00
conftest.py	refactor(workflow-file): move core.file to core.workflow.file (#32252)	2026-02-16 22:38:19 +08:00
workflow_test_utils.py	refactor(dify_graph): introduce run_context and delegate child engine creation (#32964)	2026-03-05 14:31:28 +08:00