Merge branch 'scheduling-error-handling-cancelling' into development

OFFIS-DAI · Jan 27, 2025 · 70cbadd · 70cbadd
2 parents a7a7e08 + 29cab08
commit 70cbadd
Showing 1 changed file with 10 additions and 7 deletions.
diff --git a/mango/agent/core.py b/mango/agent/core.py
@@ -433,13 +433,16 @@ def _raise_exceptions(self, fut: asyncio.Future):
         Inline function used as a callback to raise exceptions
         :param fut: The Future object of the task
         """
-        if fut.exception() is not None:
-            logger.error(
-                "Agent %s: Caught the following exception in _check_inbox: ",
-                self.aid,
-                fut.exception(),
-            )
-            raise fut.exception()
+        try:
+            if fut.exception() is not None:
+                logger.error(
+                    "Agent %s: Caught the following exception in _check_inbox: ",
+                    self.aid,
+                    fut.exception(),
+                )
+                raise fut.exception()
+        except asyncio.CancelledError:
+            pass
 
     async def _check_inbox(self):
         """Task for waiting on new message in the inbox"""