diff --git a/pyworker/job.py b/pyworker/job.py index d0338aa..c4831f6 100644 --- a/pyworker/job.py +++ b/pyworker/job.py @@ -28,6 +28,8 @@ def __init__(self, class_name, database, logger, self.job_id = job_id self.job_name = '%s#run' % class_name self.attempts = attempts + if max_backoff_delay_seconds: + max_backoff_delay_seconds = max(max_backoff_delay_seconds, 2) # max_backoff_delay_seconds can not be less than 2 seconds self.max_backoff_delay_seconds = max_backoff_delay_seconds self.run_at = run_at self.queue = queue