我试图从celery 模块导入revoke（）方法，如下所示-
from celery.tasks.control import revoke
字符串但上面写着“没有命名为'celery 任务'的模块”为什么会这样呢？所有的celery 任务都工作得很好，但是每当我试图使用其ID撤销/检查特定的celery 任务时，它会返回错误。是否有其他方法可以使用其ID撤销/检查celery 任务？
zfycwa2u1#
你从错误的celery模块调用它。您必须使用Celery对象的revoke方法，如下所示。
Celery
from celery import Celery app = Celery(__name__) # or from celery import current_app as app app.control.revoke(task_ids)
字符串您也可以使用返回的AsyncResult的revoke函数，如下所示：
async_result = add.delay(2,3) async_result.revoke()
型
1条答案
按热度按时间zfycwa2u1#
你从错误的celery模块调用它。您必须使用
Celery对象的revoke方法，如下所示。字符串
您也可以使用返回的AsyncResult的revoke函数，如下所示：
型