Getting the status of a celery task task_result = AsyncResult(task_id, app=celery_app) works correctly if you have a result backend configured and tasks are defined with @app.task(bind=True). The result would be STARTED; SUCCESS; FAILURE; RETRY; RE...
When NOT using Gevent (worker_pool\=[prefork|gthread]), the number of concurrent workers defaults to the number of cores which are effectively the tasks that will be executing in “parallel”. The prefetch multiplier (default 4) is an optimization to r...
Leverage Celery Chains to execute sequential tasks. But it wasn't clear from the documentation on how to add a delay in-between executions. The initial (reasonable) attempt: result = ( add.s(1,1) | mul.s(3) | mul.s(4) ).apply_async(countdown=5...
