We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 43bb12e commit 6c62c0fCopy full SHA for 6c62c0f
1 file changed
src/a2a/server/request_handlers/default_request_handler.py
@@ -450,12 +450,8 @@ async def _cleanup_producer(
450
try:
451
await producer_task
452
except asyncio.CancelledError:
453
- # The producer task was cancelled, which is an expected outcome in some scenarios.
454
- # We don't want to stop cleanup in this case.
455
logger.debug('Producer task %s was cancelled during cleanup', task_id)
456
except Exception:
457
- # Log other exceptions from the producer task to avoid losing error information,
458
- # but continue with the cleanup process.
459
logger.exception('Producer task %s failed during cleanup', task_id)
460
await self._queue_manager.close(task_id)
461
async with self._running_agents_lock:
0 commit comments