mirror of
https://github.com/hibiken/asynq.git
synced 2025-10-20 09:16:12 +08:00
fix: "only once" tasks should be recovered and retried on worker crash
This commit is contained in:
@@ -95,7 +95,7 @@ func (r *recoverer) recoverLeaseExpiredTasks() {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
for _, msg := range msgs {
|
for _, msg := range msgs {
|
||||||
if msg.Retried >= msg.Retry {
|
if msg.Retried >= msg.Retry && msg.Retry > 0 {
|
||||||
r.archive(msg, ErrLeaseExpired)
|
r.archive(msg, ErrLeaseExpired)
|
||||||
} else {
|
} else {
|
||||||
r.retry(msg, ErrLeaseExpired)
|
r.retry(msg, ErrLeaseExpired)
|
||||||
|
Reference in New Issue
Block a user