mirror of
https://github.com/hibiken/asynq.git
synced 2025-09-17 20:30:06 +08:00
Compare commits
3 Commits
v0.25.1
...
sohail/rec
Author | SHA1 | Date | |
---|---|---|---|
![]() |
7c3d57d30e | ||
![]() |
c327bc40a2 | ||
![]() |
ea0c6e93f0 |
@@ -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)
|
||||||
|
@@ -174,16 +174,15 @@ type Config struct {
|
|||||||
// })
|
// })
|
||||||
//
|
//
|
||||||
// ErrorHandler: asynq.ErrorHandlerFunc(reportError)
|
// ErrorHandler: asynq.ErrorHandlerFunc(reportError)
|
||||||
|
//
|
||||||
// we can also handle panic error like:
|
// we can also handle panic error like:
|
||||||
// func reportError(ctx context, task *asynq.Task, err error) {
|
// func reportError(ctx context, task *asynq.Task, err error) {
|
||||||
// if asynq.IsPanic(err) {
|
// if asynq.IsPanicError(err) {
|
||||||
// errorReportingService.Notify(err)
|
// errorReportingService.Notify(err)
|
||||||
// }
|
// }
|
||||||
// })
|
// })
|
||||||
//
|
//
|
||||||
// ErrorHandler: asynq.ErrorHandlerFunc(reportError)
|
// ErrorHandler: asynq.ErrorHandlerFunc(reportError)
|
||||||
|
|
||||||
ErrorHandler ErrorHandler
|
ErrorHandler ErrorHandler
|
||||||
|
|
||||||
// Logger specifies the logger used by the server instance.
|
// Logger specifies the logger used by the server instance.
|
||||||
|
Reference in New Issue
Block a user