Skip to content

Commit 85de502

Browse files
Kevin McConnellMatt George
authored andcommitted
Corrected retry time when retrying a failed job
1 parent edfb5e6 commit 85de502

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pyres/job.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ def retry(self, payload_class, args):
6161
retry_until = first_attempt + timedelta(seconds=retry_timeout)
6262
retry_at = now + timedelta(seconds=retry_every)
6363
if retry_at < retry_until:
64-
self.resq.enqueue_at(ResQ._current_time(), payload_class, *args,
64+
self.resq.enqueue_at(retry_at, payload_class, *args,
6565
**{'first_attempt':first_attempt})
6666
return True
6767
return False

0 commit comments

Comments
 (0)