Skip to content

Commit fb1f1c4

Browse files
committed
fix(queue.job): Handle zero max_retries in job retry logic
1 parent 11122f4 commit fb1f1c4

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

queue_job/jobrunner/runner.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -332,7 +332,7 @@ def _query_requeue_dead_jobs(self):
332332
state=(
333333
CASE
334334
WHEN
335-
max_retries IS NOT NULL AND
335+
NULLIF(max_retries, 0) IS NOT NULL AND
336336
retry IS NOT NULL AND
337337
retry>max_retries
338338
THEN 'failed'
@@ -346,7 +346,7 @@ def _query_requeue_dead_jobs(self):
346346
exc_name=(
347347
CASE
348348
WHEN
349-
max_retries IS NOT NULL AND
349+
NULLIF(max_retries, 0) IS NOT NULL AND
350350
retry IS NOT NULL AND
351351
retry>max_retries
352352
THEN 'JobFoundDead'
@@ -355,7 +355,7 @@ def _query_requeue_dead_jobs(self):
355355
exc_info=(
356356
CASE
357357
WHEN
358-
max_retries IS NOT NULL AND
358+
NULLIF(max_retries, 0) IS NOT NULL AND
359359
retry IS NOT NULL AND
360360
retry>max_retries
361361
THEN 'Job found dead after too many retries'

0 commit comments

Comments
 (0)