From d215f220e5b2eab871ccfd705681378c22af6ccb Mon Sep 17 00:00:00 2001 From: trionnis Date: Mon, 9 Mar 2026 15:33:24 -0400 Subject: [PATCH] Replace del with pop for job_tasks dictionary --- arq/worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/arq/worker.py b/arq/worker.py index de368fac..9bd45f5e 100644 --- a/arq/worker.py +++ b/arq/worker.py @@ -601,7 +601,7 @@ async def job_failed(exc: BaseException) -> None: else: result_str = '' if result is None or not self.log_results else truncate(repr(result)) finally: - del self.job_tasks[job_id] + self.job_tasks.pop(job_id, None) except (Exception, asyncio.CancelledError) as e: finished_ms = timestamp_ms()