We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fda407c commit d215f22Copy full SHA for d215f22
1 file changed
arq/worker.py
@@ -601,7 +601,7 @@ async def job_failed(exc: BaseException) -> None:
601
else:
602
result_str = '' if result is None or not self.log_results else truncate(repr(result))
603
finally:
604
- del self.job_tasks[job_id]
+ self.job_tasks.pop(job_id, None)
605
606
except (Exception, asyncio.CancelledError) as e:
607
finished_ms = timestamp_ms()
0 commit comments