How to test the tasks of a Celery instance using pytest? I am not talking about testing the Celery tasks created using the @shared_task decorator with pytest. For that, there is already a good solu...

What is the point of Celery chain if the whole chain breaks if one of the tasks fail?!! I have this Celery chain: res = chain(workme.s ( y=1111 ), workme2.s( 2222 ), workme3.s( 3333 ),)() And ...

I am using Celery 3.0 and have the configuration file like below. celeryconfig.py BROKER_URL = 'redis://localhost:6379/0' CELERY_RESULT_BACKEND = 'redis://localhost:6379/0' CELERY_TASK_SERIALIZER...

UPDATE: I decided to try using Django as the broker for simplicity, as I assumed I did something wrong in the Redis setup. However, after making the changes described in the docs I get the same err...

Please help me to get out of this problem I am getting this when I am running celery -A app.celery worker --loglevel=info Error: Unable to load celery application. The module app.celery was not...

I need to replace my redis broker with SQS broker, while googleing it I came across many pages which tell how to use SQS with celery. As per my understanding, it creates own SQS queue, I have only ...

I am unit testing celery tasks. I have chain tasks that also have groups, so a chord is resulted. The test should look like: run celery task ( delay ) wait for task and all subtasks assert I t...

I have django 1.11.5 app with celery 4.1.0 and I recived all the time: kombu.exceptions.EncodeError: <User: testuser> is not JSON serializable my settings.py: CELERY_BROKER_URL = 'amqp://...

After many days I have a working celery and celery beat task list, and the results are stored using django_celery_results. However when I look at the table record, it hasn't got any useful informat...

I keep getting this keyError. I'm sending strings and id (integers) to the task function, so I don't think it is serialization issue. Also it says the keyerror is on the path to the function itself...

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

I have a celery task which sends data to another service. I have added the celery task send_inventory_request into RequestSupplyStock class based view. when I make a post I should first get results...

I am newbie to Celery. I create a project as per instruction provided by the celery4.1 docs.Below is my project folder and files: mycelery | test_celery | celery_app.py tasks.py __init__.py...

I'm a bit new in celery configs. I have a task named myapp.tasks.my_task for example. I can see myapp.tasks.my_task in registered tasks of celery when I use celery inspect registered. doesn't it me...

Under some conditions, I want to make a celery task fail from within that task. I tried the following: from celery.task import task from celery import states @task() def run_simulation(): if som...

I have a couple of celery tasks that are included in my Django tests. Unfortunately exceptions are not thrown when tasks are invoked via .delay(). I am setting CELERY_ALWAYS_EAGER to True. tasks.p...

File "C:\Users\Codertjay\PycharmProjects\Teems_App_Kid\teems_app_kid\__init__.py", line 5, in <module> from .celery import app as celery_app File "C:\Users\Codertjay\PycharmP...

I have recently started working on distributed computing for increasing the computation speed. I opted for Celery. However, I am not very familiar with some terms. So, I have several related questi...

I am using celery with a fastAPI. Getting Can't decode message body: ContentDisallowed('Refusing to deserialize untrusted content of type json (application/json)') while running in docker. When run...

We have a Celery task that requires a Pandas dataframe as an input. The dataframe is first serialized to JSON and then passed as an argument into the task. The dataframes can have around 35 thousan...

So we have a kubernetes cluster running some pods with celery workers. We are using python3.6 to run those workers and celery version is 3.1.2 (I know, really old, we are working on upgrading it). ...

Celery - bottom line: I want to get the task name by using the task id (I don't have a task object) Suppose I have this code: res = chain(add.s(4,5), add.s(10)).delay() cache.save_task_id(res.task_...

First of all please don't consider this question as a duplicate of this question I have a setup an environment which uses celery and redis as broker and result_backend. My question is how can I m...

I've launched a lot of tasks, but some of then hasn't finished (763 tasks), are in a PENDING state, but the system isn't processing anything... It's possible to retry this tasks giving celery the t...

i looked at celery documentation and trying something from it but it not work like the example. maybe i'm wrong at some point, please give me some pointer if i'm wrong about the following code in ...