go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-12-24 23:02:18 +08:00
Code Issues Projects Releases Wiki Activity

allow cancel without retry

Browse Source
This commit is contained in:
thedmdim 2024-12-16 21:30:26 +04:00
parent 489e21920b
commit 35edb0281b
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
processor.go
View File

@ -336,15 +336,18 @@ func (p *processor) handleFailedMessage(ctx context.Context, l *base.Lease, msg
p.errHandler.HandleError(ctx, NewTask(msg.Type, msg.Payload), err)
}
switch {
case errors.Is(err, RevokeTask):
p.logger.Warnf("revoke task id=%s", msg.ID)
p.markAsDone(l, msg)
case msg.Retried >= msg.Retry || errors.Is(err, SkipRetry):
p.logger.Warnf("Retry exhausted for task id=%s", msg.ID)
p.archive(l, msg, err)
default:
p.retry(l, msg, err, p.isFailureFunc(err))
}
case errors.Is(err, RevokeTask):
p.logger.Warnf("Revoke task id=%s", msg.ID)
p.markAsDone(l, msg)
case ctx.Err() == context.Canceled || errors.Is(err, SkipRetry):
p.logger.Warnf("Task canceled, skipping retry for id=%s", msg.ID)
p.archive(l, msg, err)
case msg.Retried >= msg.Retry:
p.logger.Warnf("Retry exhausted for task id=%s", msg.ID)
p.archive(l, msg, err)
default:
p.retry(l, msg, err, p.isFailureFunc(err))
}
}
func (p *processor) retry(l *base.Lease, msg *base.TaskMessage, e error, isFailure bool) {