diff --git a/sync/zenith/sync/processor/base.py b/sync/zenith/sync/processor/base.py index 81df87bb..99f14761 100644 --- 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",