Python Developer

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

I am building REST API with Flask-restplus. One of my endpoints takes a file uploaded from client a… Read more How Do I Run Background Job In Flask Without Threading Or Task-queue

In docs link about expires # Task expires after one minute from now. add.apply_async(args=[10, 10],… Read more Celery Expires - Rise Exception

I am using celery to run long running tasks on Hadoop. Each task executes a Pig script on Hadoop wh… Read more Initializing Different Celery Workers With Different Values

I have a celery task which takes about 6 hours. At the end of it, Django (or possibly Celery) rais… Read more Long Celery Task Causes Mysql Timeout In Django - Options?

I'm trying to pause a celery task temporary based on user button click. What I've done is: … Read more Pause Celery Task