the part where you explained about how celery used all the cores of the machine by default to support multiprocessing is very well done. thank you sir.
I have one silly doubt at 19:45 . When, you ran the script, why did the second print statement for write_log also take 5 seconds if sleep(5) was implemented for TaskQueue ?
Because the client didn't reach the write log line until sleep was completed because it was waiting on the result from TaskQueue. The write log completed instantly, Just that it was called after 5 seconds.
Great explanation, sir. But, What if I want to one task call another task passing a JSON object as a message between them? Is It possible and How is it? Thank you.
Hi, I've presented the same topic in PyCon 2024, here is the repo link of the same github.com/CognitiveProgrammer/PyCon2024-Celery It also has all the presentation I've used in tutorial. Hope it helps
the part where you explained about how celery used all the cores of the machine by default to support multiprocessing is very well done. thank you sir.
Thank you so much for your kind comment 🙏
this was an incredibly well articulated video!
Thank you so much 🙏
one of the best and esay explantion Thank you sir can you make video on golang
Thank you so much for your kind words.. yes I do have some videos on golang in my channel and also planning to start a series
Very easy to understand, thank you
Thanks for your comment 🙏
Very nice. Only confusion I still have is, suppose I host celery on other container. How can I then call the celery function?
Thank you
Not sure if I understood your question but celery across machines or containers are registered via message brokers I.e. rabbitmq or redis
When hosting Celery in a separate container, you typically communicate with it using a message broker like RabbitMQ or AWS SQS .
I have one silly doubt at 19:45 . When, you ran the script, why did the second print statement for write_log also take 5 seconds if sleep(5) was implemented for TaskQueue ?
Because the client didn't reach the write log line until sleep was completed because it was waiting on the result from TaskQueue. The write log completed instantly, Just that it was called after 5 seconds.
Other question: How can I call an async function from inside of a celery task function? Is it possible?
Great explanation, sir. But, What if I want to one task call another task passing a JSON object as a message between them? Is It possible and How is it? Thank you.
how r u running it on the vscode terminal? its very confusing
what is that long command you are running on the vsc terminal at 11.00?????????
Sir, Can this task queue be Kafka as well?
Not officially supported, but I believe there are some ways to implement it. I'm sorry, I'm not so sure on this.
Hi, how can I access the material you use in Pycon24? Thank you.
Thanks for your comment - Here is the GitHub link for the same github.com/CognitiveProgrammer/PyCon2024-Celery
@@Cognitive-Programmer thank you so much
can you post a repo?
Hi, I've presented the same topic in PyCon 2024, here is the repo link of the same github.com/CognitiveProgrammer/PyCon2024-Celery
It also has all the presentation I've used in tutorial. Hope it helps
CFBR
Thank you so much 🙏