Python Guru

I have 3 machines with celery workers and rabbitmq as a broker, one worker is running with beat fla… Read more Celery Dies With Dbpagenotfounderror

Suppose i have this task definition: def some_other_foo(input) raise Exception('This is not han… Read more Celery Exception Handling

I am having a requirement in my project where customer can pause or resume process which are pendin… Read more How To Pause Or Resume Celery Task?

I have 2 types of task: async tasks and schedule tasks. So, here is my dir structure: proj | --… Read more How To Structure Celery Tasks

I integrated my project with celery in this way, inside views.py after receving request from the us… Read more How To Provide User Constant Notification About Celery's Task Execution Status?

I am working on a small but computationally-intensive Python app. The computationally-intensive wor… Read more Concurrent Asynchronous Processes With Python, Flask And Celery

I installed django-celery and I tried to start up the worker server but I get an OSError that a fun… Read more Django Celery Implementation - Oserror : [errno 38] Function Not Implemented

I have a celery job to run MySQL databases, however, it always got Lock Wait Timeout. After digging… Read more Why Does Celery Retry, But My Job Did Not Fail?

I am adding airflow to a web application that manually adds a directory containing business logic t… Read more How To Run Airflow With Celeryexecutor On A Custom Docker Image

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?

I have the following setup with a fresh installed celery and django 1.4: settings.py: import djcel… Read more Celery: Auto Discovery Does Not Find Tasks Module In App

I'm having an issue getting access to models in my tasks.py My goal is to send an email at var… Read more Celery - Importing Models In Tasks.py

How can I capture without running Celery tasks created during a unit test? For example, I'd lik… Read more How Do I Capture Celery Tasks During Unit Testing?

I have a simple application that sends & receives messages, kombu, and uses Celery to task the … Read more Kombu/celery Messaging

Currently we have everything setup on single cloud server, that includes: Database server Apache C… Read more Django-celery Infrastructure Over Multiple Servers, Broker Is Redis

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?

I'm banging my head to the wall with celeryd and RabbitMQ. This example from tutorial is worki… Read more Celeryd With RabbitMQ Hangs On "mingle: Searching For Neighbors", But Plain Celery Works

So in my flask app right now I am using Celery to deploy servers on remote machines. Right now, I h… Read more How Do You Deal With An Exception Raised By Celery (not Your Code)?

I have ETA tasks that get sent to a Redis broker for Celery. It is a single celery and redis instan… Read more Same Task Executed Multiple Times

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