Top "Celery-task" questions

celery-task is a building block of Celery distributed task queue system

Deleting all pending tasks in celery / rabbitmq

How can I delete all pending tasks without knowing the task_id for each task?

task rabbitmq celery celery-task
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 …

python flask celery celery-task
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 …

python django celery django-celery celery-task
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 celery celery-task airflow
Celery task state always pending

I am pretty new to celery and django in general so please excuse my lack of knowledge. I am trying …

python django celery django-celery celery-task
how to remove task from celery with redis broker?

I Have add some wrong task to a celery with redis broker but now I want to remove the incorrect …

python celery celery-task celeryd
import error in celery

this is the code which i am running: from __future__ import absolute_import from celery import Celery celery1 = Celery('celery',…

python celery pycharm celery-task
Celery: list all tasks, scheduled, active *and* finished

Update for the bounty I'd like a solution that does not involve a monitoring thread, if possible. I know I …

celery celery-task
How to make a celery task fail from within the task?

Under some conditions, I want to make a celery task fail from within that task. I tried the following: from …

celery celery-task
Celery AttributeError: async error

I have RabbitMQ and Celery running locally on my Mac (OS/X 10.13.4), the following code works locally when I run …

python celery celery-task