Skip to content

Commit f72ada0

Browse files
author
aezell
committed
Let's push before we delete to make sure we don't lose anything.
1 parent 4391047 commit f72ada0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pyres/failure/__init__.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,8 @@ def requeue(resq, failure_object):
2424

2525
def retry(resq, queue, payload):
2626
job = resq.decode(payload)
27-
delete(resq, payload)
28-
return resq.push(queue, job['payload'])
27+
resq.push(queue, job['payload'])
28+
return delete(resq, payload)
2929

3030
def delete(resq, payload):
3131
return resq.redis.lrem(name = 'resque:failed', num = 1, value = payload)

0 commit comments

Comments
 (0)