go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-11-15 03:48:44 +08:00
Code Issues Projects Releases Wiki Activity

delete processed when deleting a queue

Browse Source 
#508
This commit is contained in:
hansongyu 2022-07-13 10:04:40 +08:00 committed by GitHub
parent aefd276146
commit 053a5b8daa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
internal/rdb/inspect.go
View File

@ -1818,6 +1818,7 @@ func (r *RDB) RemoveQueue(qname string, force bool) error {
base.RetryKey(qname), base.RetryKey(qname),
base.ArchivedKey(qname), base.ArchivedKey(qname),
base.LeaseKey(qname), base.LeaseKey(qname),
base.ProcessedTotalKey(qname),
} }
res, err := script.Run(context.Background(), r.client, keys, base.TaskKeyPrefix(qname)).Result() res, err := script.Run(context.Background(), r.client, keys, base.TaskKeyPrefix(qname)).Result()
if err != nil { if err != nil {