how to remove task from celery with redis broker?

python celery celery-task celeryd
timger picture timger · Jun 19, 2013 · Viewed 18.1k times · Source

I Have add some wrong task to a celery with redis broker

but now I want to remove the incorrect task and I can't find any way to do this

Is there some commands or some api to do this ?

Answer

Artem Mezhenin picture Artem Mezhenin · Jun 22, 2013

I know two ways of doing so:

1) Delete queue directly from broker. In your case it's Redis. There are two commands that could help you: llen (to find right queue) and del (to delete it).

2) Start celery worker with --purge or --discard options. Here is help:

--purge, --discard    Purges all waiting tasks before the daemon is started.
                      **WARNING**: This is unrecoverable, and the tasks will
                      be deleted from the messaging server.

Related questions

Celery Worker Error: ImportError no module named celery

I am getting an import error when I try to start my celery worker. I am not sure what the issue is. Any help would be highly appreciated. My project: email/__init__.py /celery.py I try to run the …

Read More
How can I run a celery periodic task from the shell manually?

I'm using celery and django-celery. I have defined a periodic task that I'd like to test. Is it possible to run the periodic task from the shell manually so that I view the console output?

Read More
Airflow - Python file NOT in the same DAG folder

I am trying to use Airflow to execute a simple task python. from __future__ import print_function from airflow.operators.python_operator import PythonOperator from airflow.models import DAG from datetime import datetime, timedelta from pprint import pprint seven_days_…

Read More