To mark a task as failed without raising an exception, update the task state to FAILURE and then raise an Ignore exception, because returning any value will record the task as successful, an example: from celery import Celery, states from celery.exceptions import Ignore app = Celery(‘tasks’, broker=”amqp://guest@localhost//”) @app.task(bind=True) def run_simulation(self): if some_condition: # manually update … Read more
We sorted by just updating to celery==4.1.1 it seems the latest release for the 4.1.X sorted out the module name change on kombu
Don’t use #2 unless you are using celery v3. If you are using celery v4, use #1. Use #3 in instances where you are writing a reusable library or django app. For example, if you are writing an open source set of tasks that allow you to manage aws ec2 instances using celery, you would … Read more
Have you tried just running the task from the Django shell? You can use the .apply method of a task to ensure that it is run eagerly and locally. Assuming the task is called my_task in Django app myapp in a tasks submodule: $ python manage.py shell >>> from myapp.tasks import my_task >>> eager_result = … Read more
From the docs: $ celery -A proj purge or from proj.celery import app app.control.purge() (EDIT: Updated with current method.)