Skip to content Skip to sidebar Skip to footer
Showing posts with the label Celery

Celery: Is There A Way To Write Custom Json Encoder/decoder?

I have some objects I want to send to celery tasks on my application. Those objects are obviously n… Read more Celery: Is There A Way To Write Custom Json Encoder/decoder?

How To Inspect And Cancel Celery Tasks By Task Name

I'm using Celery (3.0.15) with Redis as a broker. Is there a straightforward way to query the n… Read more How To Inspect And Cancel Celery Tasks By Task Name

Celery Heartbeat Not Working

I have set heartbeat in Celery settings: BROKER_HEARTBEAT = 10 I have also set this configuration … Read more Celery Heartbeat Not Working

Python Celery - Get() Is Delayed

I am running the following simple example. Submit 20 jobs that take 2 seconds each using a single w… Read more Python Celery - Get() Is Delayed

Rabbitmq Queued Messages Keep Increasing

We have a Windows based Celery/RabbitMQ server that executes long-running python tasks out-of-proce… Read more Rabbitmq Queued Messages Keep Increasing

Celery Does Not Release Memory

It looks like celery does not release memory after task finished. Every time a task finishes, there… Read more Celery Does Not Release Memory

How Can I Properly Kill A Celery Task In A Kubernetes Environment?

How can I properly kill celery tasks running on containers inside a kubernetes environment? The str… Read more How Can I Properly Kill A Celery Task In A Kubernetes Environment?

How Can Celery Distribute Users' Tasks In A Fair Way?

The task I'm implementing is related to scrape some basic info about a URL, such as title, desc… Read more How Can Celery Distribute Users' Tasks In A Fair Way?

Celery Flower - How Can I Load Previous Catched Tasks?

I started to use celery flower for tasks monitoring and it is working like a charm. I have one conc… Read more Celery Flower - How Can I Load Previous Catched Tasks?

How To Daemonize Django Celery Periodic Task On Ubuntu Server?

On localhost, i used these statements to execute tasks and workers. Run tasks: python manage.py cel… Read more How To Daemonize Django Celery Periodic Task On Ubuntu Server?

Start Celery Worker And Enable It For Broadcast Queue

I'm trying to start celery worker so it only listens to single queue. This is not a problem, I … Read more Start Celery Worker And Enable It For Broadcast Queue

Task Priority In Celery With Redis

I would like to implement a distributed job execution system with celery. Given that rabbitMQ doesn… Read more Task Priority In Celery With Redis

Django Related Objects Are Missing From Celery Task (race Condition?)

Strange behavior, that I don't know how to explain. I've got a model, Track, with some rela… Read more Django Related Objects Are Missing From Celery Task (race Condition?)

Get Progress From Async Python Celery Chain By Chain Id

I'm trying to get the progress of a task chain by querying each task status. But when retrievin… Read more Get Progress From Async Python Celery Chain By Chain Id

Celery Task For File Uploading In Django Wizard

I have a WizardView covering two forms, the second one has a FileField. Is it possible to create a … Read more Celery Task For File Uploading In Django Wizard

Is It Possible To Use Django Models Module Only In My Project?

I am developing a small independent python application which uses Celery. I have built this using d… Read more Is It Possible To Use Django Models Module Only In My Project?

How To Test If Email Was Sent After Executing Celery Task

I'm using Django 1.10 and Celery 4.1 I have a shared_task which sends an email to the user. # m… Read more How To Test If Email Was Sent After Executing Celery Task