Don't raise exception in task_done when cancelled

mosquito · Feb 20, 2023 · fffa397 · fffa397
1 parent 69efad5
commit fffa397
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/aiormq/base.py b/aiormq/base.py
@@ -35,9 +35,12 @@ def remover(*_: Any) -> None:
             if future in self.futures:
                 self.futures.remove(future)
 
-            exc = future.exception()
-            if exc is not None:
-                raise exc
+            try:
+                exc = future.exception()
+                if exc is not None:
+                    raise exc
+            except asyncio.CancelledError:
+                pass
 
         return remover