dify/api/tests/test_containers_integration...
QuantumGhost feaad67531 feat(api): Introduce Broadcast Channel (#27835)
This PR introduces a `BroadcastChannel` abstraction with broadcasting and at-most once delivery semantics, serving as the communication component between celery worker and API server.

It also includes a reference implementation backed by Redis PubSub.

Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com>
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
2025-11-14 14:43:12 +08:00
..
core refactor: implement tenant self queue for rag tasks (#27559) 2025-11-14 14:43:12 +08:00
factories chore: add ast-grep rule to convert Optional[T] to T | None (#25560) 2025-09-15 13:06:33 +08:00
libs/broadcast_channel/redis feat(api): Introduce Broadcast Channel (#27835) 2025-11-14 14:43:12 +08:00
services feat: implement file extension blacklist for upload security (#27540) 2025-11-04 15:45:22 +08:00
tasks refactor: implement tenant self queue for rag tasks (#27559) 2025-11-14 14:43:12 +08:00
workflow Feat add testcontainers test (#23269) 2025-08-04 19:27:36 +08:00
__init__.py Feat add testcontainers test (#23269) 2025-08-04 19:27:36 +08:00
conftest.py Feature add test containers mail email code login task (#26580) 2025-10-05 12:44:40 +08:00
test_workflow_pause_integration.py feat(api): Introduce workflow pause state management (#27298) 2025-10-30 14:41:09 +08:00