1个回答

test
2024-06-29
找到解决办法了,应该使用 inspector
。
var err error
inspector := asynq.NewInspector(asynq.RedisClientOpt{Addr: "localhost:6379"})
err = inspector.CancelProcessing(id)
if err != nil {
log.Fatalln("cancel task failed", err)
}
err = inspector.ArchiveTask("default", id)
if err != nil {
log.Fatalln("archive task failed", err)
}
回复

适合作为回答的
- 经过验证的有效解决办法
- 自己的经验指引,对解决问题有帮助
- 遵循 Markdown 语法排版,代码语义正确
不该作为回答的
- 询问内容细节或回复楼层
- 与题目无关的内容
- “赞”“顶”“同问”“看手册”“解决了没”等毫无意义的内容