fix(agent_execution): resolve ActiveTask 'destroyed but pending' warning during teardown#1122
Conversation
![gemini-code-assist[bot]](https://avatars.githubusercontent.com/in/956858?s=60&v=4){kind=small}
There was a problem hiding this comment.
Code Review
This pull request updates the _run_consumer method in active_task.py to await the _producer_task if it is not yet completed during shutdown. The review feedback correctly identifies that asyncio.CancelledError inherits from BaseException rather than Exception in Python 3.8+, meaning a cancellation error would propagate and bypass critical cleanup steps like decrementing the reference count. A code suggestion is provided to explicitly catch and handle asyncio.CancelledError.
Important
The consumer version of Gemini Code Assist on GitHub is being sunset. Starting June 18, 2026, new organization installations will be blocked, and all code review activity will officially cease on July 17, 2026.
For more details on the timeline and next steps, please review the Help Documentation.
🧪 Code Coverage (vs
|
| Base | PR | Delta | |
|---|---|---|---|
| src/a2a/server/agent_execution/active_task.py | 95.76% | 95.32% | 🔴 -0.43% |
| Total | 92.97% | 92.95% | 🔴 -0.02% |
Generated by coverage-comment.yml
…ing during teardown
7b9e59a to
af85738
Compare
arunmm8335
changed the title
2 participants
Fixes #1121. This PR resolves the issue where
ActiveTaskwould throw an asyncio warning when being garbage collected, by ensuring the_producer_taskis properly awaited during the_run_consumerteardown path, allowing queues to properly close without leaving dangling pending background tasks.