Fix agent progress frames on live WebSocket (#63) #72

Merged
westfarn merged 1 commits from fix/63-agent-ws-send-fanout into master 2026-08-04 06:26:26 -07:00
Owner

Summary

  • Follow-up to #71 / #63.
  • Bugfix: run_agentic_turn discarded ws_send, so run_started / plan_ready / step_* / run_completed frames only hit an empty Redis group and never the connected client during inline agent runs.
  • Thread ws_send through execute_agent_run / _broadcast (WS + channel-layer group).
  • Route agentic turns in consumers_graph the same way as consumers.py.
  • Add offline test_agent_orchestrator.py coverage.

Test plan

  • SKIP_RAG_INIT=1 uv run python manage.py test chat_backend.tests.test_agent_orchestrator chat_backend.tests.test_agent_tools chat_backend.tests.test_consumers
  • Manual: ALLOW_AGENTIC_TASKS=true, multi-step prompt — confirm agent frames arrive on the live WS
  • Manual: graph consumer path (ws/conditional_chat/) also routes agentic turns
## Summary - Follow-up to [#71](https://git.aimloperations.com/ai_ml_operations/chat_backend/pulls/71) / [#63](https://git.aimloperations.com/ai_ml_operations/chat_backend/issues/63). - **Bugfix:** `run_agentic_turn` discarded `ws_send`, so `run_started` / `plan_ready` / `step_*` / `run_completed` frames only hit an empty Redis group and never the connected client during inline agent runs. - Thread `ws_send` through `execute_agent_run` / `_broadcast` (WS + channel-layer group). - Route agentic turns in `consumers_graph` the same way as `consumers.py`. - Add offline `test_agent_orchestrator.py` coverage. ## Test plan - [x] `SKIP_RAG_INIT=1 uv run python manage.py test chat_backend.tests.test_agent_orchestrator chat_backend.tests.test_agent_tools chat_backend.tests.test_consumers` - [ ] Manual: `ALLOW_AGENTIC_TASKS=true`, multi-step prompt — confirm agent frames arrive on the live WS - [ ] Manual: graph consumer path (`ws/conditional_chat/`) also routes agentic turns
westfarn added 1 commit 2026-08-04 04:29:57 -07:00
Fix agent progress frames reaching the live WebSocket (#63).
CI / test (pull_request) Successful in 11s
Unit Tests / test (pull_request) Successful in 11s
72f1f87765
Thread ws_send through execute_agent_run/_broadcast so inline agent turns
emit run/step frames on the connected client, not only the Redis group.
Also route agentic tasks in consumers_graph and add orchestrator unit tests.
westfarn merged commit bef151c92c into master 2026-08-04 06:26:26 -07:00
westfarn deleted branch fix/63-agent-ws-send-fanout 2026-08-04 06:26:26 -07:00
Sign in to join this conversation.
No Reviewers
No labels
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: ai_ml_operations/chat_backend#72