dify/api/tests/test_containers_integration_tests/libs
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
..
broadcast_channel/redis fix(api): StreamsBroadcastChannel start reading messages from the end (#34030) 2026-03-25 10:21:57 +08:00
test_auto_renew_redis_lock_integration.py fix(api): make DB migration Redis lock TTL configurable and prevent LockNotOwnedError from masking failures (#32299) 2026-02-14 14:55:05 +08:00
test_rate_limiter_integration.py feat: Human Input Node (#32060) 2026-02-09 14:57:23 +08:00