fix: prevent deadlock by returning messages directly instead of queueing#978

Open

devin-ai-integration[bot] wants to merge 5 commits intomainfrom

devin/1775123731-deadlock-fix-direct-return

Commits on Apr 2, 2026

fix: prevent deadlock by returning messages directly instead of queueing

devin-ai-integration[bot]
and
Anatolii Yatsuk (tolik0)
committed
style: fix ruff formatting in substream_partition_router.py

devin-ai-integration[bot]
and
Anatolii Yatsuk (tolik0)
committed
fix: add expected STATE messages to integration test for direct-return approach

devin-ai-integration[bot]
and
Anatolii Yatsuk (tolik0)
committed
fix: consume ensure_at_least_one_state_emitted generator in perpartition cursor tests

devin-ai-integration[bot]
and
Anatolii Yatsuk (tolik0)
committed
fix: make mock cursor ensure_at_least_one_state_emitted return iterable in substream tests

devin-ai-integration[bot]
and
Anatolii Yatsuk (tolik0)
committed