go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-01-13 00:13:39 +08:00
Code Issues Projects Releases Wiki Activity

fix: avoid retry if MaxRetry zero

Browse Source
This commit is contained in:
mindon 2023-07-12 10:46:55 +08:00
parent 8c0d758eef
commit 1fe0d81544
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
processor.go
View File

@ -322,6 +322,12 @@ func (p *processor) markAsDone(l *base.Lease, msg *base.TaskMessage) {
var SkipRetry = errors.New("skip retry for the task") var SkipRetry = errors.New("skip retry for the task")
func (p *processor) handleFailedMessage(ctx context.Context, l *base.Lease, msg *base.TaskMessage, err error) { func (p *processor) handleFailedMessage(ctx context.Context, l *base.Lease, msg *base.TaskMessage, err error) {
if msg.Retry == 0 {
if errors.Is(err, SkipRetry) {
p.markAsDone(l, msg)
return
}
}
if p.errHandler != nil { if p.errHandler != nil {
p.errHandler.HandleError(ctx, NewTask(msg.Type, msg.Payload), err) p.errHandler.HandleError(ctx, NewTask(msg.Type, msg.Payload), err)
} }
@ -339,7 +345,7 @@ func (p *processor) handleFailedMessage(ctx context.Context, l *base.Lease, msg
} }
func (p *processor) retry(l *base.Lease, msg *base.TaskMessage, e error, isFailure bool) { func (p *processor) retry(l *base.Lease, msg *base.TaskMessage, e error, isFailure bool) {
if !l.IsValid() { if !l.IsValid() || msg.Retry == 0 {
// If lease is not valid, do not write to redis; Let recoverer take care of it. // If lease is not valid, do not write to redis; Let recoverer take care of it.
return return
} }