We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5430f90 commit 536258cCopy full SHA for 536258c
plain-worker/plain/worker/models.py
@@ -331,6 +331,9 @@ def retry_job(self, delay: int | None = None):
331
job = jobs_registry.load_job(self.job_class, self.parameters)
332
retry_delay = delay or job.get_retry_delay(retry_attempt)
333
334
+ # TODO a job class could have been deleted, and it would fail to load.
335
+ # What do we do then? Increment the retry attempt and leave it in the db?
336
+
337
with transaction.atomic():
338
result = job.run_in_worker(
339
# Pass most of what we know through so it stays consistent
0 commit comments