quq*_*123 7 django scheduled-tasks celery celery-task django-celery
我无法理解 Celery 队列和撤销。我的主要问题是,如果创建了具有相同名称和参数的新任务,如何撤销(停止执行)队列中已有的任务。所以在伪代码中
new_task_to_be_added = some_task(1,2)
if exists some_task in queue where some_task.args = (1,2):
remove such task from queue
new_task_to_be_added.add_to_queue()
Run Code Online (Sandbox Code Playgroud)
这与密码重置机制相关 - 用户单击“创建临时密码”,并有 5 分钟的时间使用此密码创建新的永久密码。如果此时未设置新密码,则帐户应被锁定。但是,如果在 4 分钟后用户创建了一个新的临时密码,他应该再次有 5 分钟的时间来更改它,但“锁定帐户”任务将在 1 分钟内触发 - 我想停止它并始终只使用最新的任务(使用相同参数)
这不是以下内容的副本: Revoke celerytaskswithsameargs/kwargs 这实际上是相反的问题
| 归档时间: |
|
| 查看次数: |
311 次 |
| 最近记录: |