diff --git a/src/saturn_engine/worker/executors/queue.py b/src/saturn_engine/worker/executors/queue.py index 24cff16d..b2ae62a4 100644 --- a/src/saturn_engine/worker/executors/queue.py +++ b/src/saturn_engine/worker/executors/queue.py @@ -58,7 +58,7 @@ async def run_queue(self) -> None: while self.is_running: processable = await self.poll() processable._executing_context.callback(self.queue.task_done) - with contextlib.suppress(Exception), processable.saturn_context(): + with contextlib.suppress(BaseException), processable.saturn_context(): async with ( processable._context, processable._executing_context,