我计划这样的任务 -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