diff --git a/lib/crewai/src/crewai/utilities/streaming.py b/lib/crewai/src/crewai/utilities/streaming.py index e0ea5b1f0..cc5eb1990 100644 --- a/lib/crewai/src/crewai/utilities/streaming.py +++ b/lib/crewai/src/crewai/utilities/streaming.py @@ -335,7 +335,10 @@ async def create_async_chunk_generator( yield item finally: if not cancel_event.is_set(): - await task + try: + await task + except (asyncio.CancelledError, Exception): # noqa: S110 + pass else: if not task.done(): task.cancel()