Skip to content

Commit ef00b65

Browse files
zamberjoAnizR
authored andcommitted
fix(queue.job): Handle zero max_retries in job retry logic
1 parent 8a346da commit ef00b65

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

queue_job/jobrunner/runner.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -331,6 +331,7 @@ def _query_requeue_dead_jobs(self):
331331
CASE
332332
WHEN
333333
max_retries IS NOT NULL AND
334+
max_retries != 0 AND -- infinite retries if max_retries is 0
334335
retry IS NOT NULL AND
335336
retry>max_retries
336337
THEN 'failed'
@@ -345,6 +346,7 @@ def _query_requeue_dead_jobs(self):
345346
CASE
346347
WHEN
347348
max_retries IS NOT NULL AND
349+
max_retries != 0 AND -- infinite retries if max_retries is 0
348350
retry IS NOT NULL AND
349351
retry>max_retries
350352
THEN 'JobFoundDead'
@@ -354,6 +356,7 @@ def _query_requeue_dead_jobs(self):
354356
CASE
355357
WHEN
356358
max_retries IS NOT NULL AND
359+
max_retries != 0 AND -- infinite retries if max_retries is 0
357360
retry IS NOT NULL AND
358361
retry>max_retries
359362
THEN 'Job found dead after too many retries'

0 commit comments

Comments
 (0)