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

Minor fix

Browse Source
This commit is contained in:
Ken Hibino 2021-01-19 20:56:58 -08:00
parent f76b8ae9c0
commit e8e401578f
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/rdb/inspect.go
View File

@ -692,9 +692,13 @@ func (r *RDB) DeletePendingTask(qname string, id uuid.UUID) error {
return err
}
if msg.ID == id {
if err := r.client.LRem(qkey, 1, s).Err(); err != nil {
n, err := r.client.LRem(qkey, 1, s).Result()
if err != nil {
return err
}
if n == 0 {
return ErrTaskNotFound
}
return nil
}
}