I've followed each step of part 1 chapter 4 and literally copy pasted the code as shown. docker-compose is able to build the containers but I always get the Waiting for PostgresSQL to become available being logged from all the…
My docker-compose creates 3 containers - django, celery and rabbitmq. When i run the following commands -> docker-compose build and docker-compose up, the containers run successfully. However I am having issues with deploying the image. The image generated has an…
I am trying to run my django application using docker which involves celery. I am able to set everything on local and it works perfectly fine. However, when I run it docker, and my task gets executed, it throws me…
I am attempting to run celery on it's own container from my Flask app. Right now I am just setting up a simple email app. The container CMD is "["celery", "worker", "--loglevel=info"]" The message gets sent to the redis broker…
Given a pipeline of tasks that run in sequence. Each task consumes data from the database, manipulate it, and produces (write) to the same database. We are using AWS RDS Aurora, and in order to spread the load, the “reading…
I have the following application I'm working on but I have an error that I can't figure out what I should do. The application is as follows the user adds a link to a video, the task is sent to…
I am trying to make a task with celery using redis as broker and backend with fastapi. I am new to this so I do not know what am I doing wrong. I am following this tutorial: https://www.youtube.com/watch?v=mcX_4EvYka4 I am…
I am looking to run tasks in parallel with django celery. Let's say the following task: @shared_task(bind=True) def loop_task(self): for i in range(10): time.sleep(1) print(i) return "done" Each time a view is loaded then this task must be executed :…
I am trying to test an API that sends long-running jobs to a queue processed by Celery workers.. I am using RabbitMQ running in a Docker container as the message queue. However, when sending a message to the queue I…
In my web-application I start backgrounds jobs with celery without storing their id. Some of the task are periodic and some are triggered by user-interaction. The celery-tasks just do their thing and eventually the user will see the updated data…