Ignore timeout error from cancel wait (#379)

stackhpc · May 17, 2024 · 030453a · 030453a
1 parent bb6174b
commit 030453a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sync/zenith/sync/processor/base.py b/sync/zenith/sync/processor/base.py
@@ -103,7 +103,7 @@ async def schedule_task(
             # Wait for the task to actually finish cancelling
             try:
                 await asyncio.wait_for(existing_task, 10)
-            except asyncio.CancelledError:
+            except (asyncio.CancelledError, asyncio.TimeoutError):
                 pass
         self.logger.info(
             "Scheduling task to process %s event for %s",