go asynq 怎么取消任务?

作者站长头像
站长
· 阅读数 16

用过 asynq 的小伙伴帮忙看下怎么根据任务ID取消任务

https://github.com/hibiken/asynq

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