2

我计划这样的任务 -task_id = function_with_celery_decorator.delay(args).id然后尝试做:

from celery.app.control import Control
celery_control = Control()
celery_control.revoke(task_id_got_from_db)

但没有结果 - 任务仍然会完成,并且在两者的控制台中的日志中都有注释

python manage.py celeryd -l INFO &
python manage.py runserver 0.0.0.0:$PORT
4

0 回答 0