Fix unintended cancellation of fetcher task (#1007)

* Fix unintented cancellation of fetcher task * Update aiokafka/consumer/fetcher.py Co-authored-by: Denis Otkidach <denis.otkidach@gmail.com> --------- Co-authored-by: Denis Otkidach <denis.otkidach@gmail.com>
aio-libs · May 12, 2024 · 79c9bf5 · 79c9bf5
1 parent c759664
commit 79c9bf5
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/aiokafka/consumer/fetcher.py b/aiokafka/consumer/fetcher.py
@@ -512,7 +512,8 @@ def on_done(fut, self=self):
                         # cancellation
                         if not task.done():
                             task.cancel()
-                        await task
+                        with contextlib.suppress(asyncio.CancelledError):
+                            await task
                     self._pending_tasks.clear()
                     self._records.clear()