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()