This is a bit of theoretical question and I cant find a clean cut answer in any celery documentation I ve read. So assume we have a Flask app and also Celery with either redis
or rabbitmq
. Now the broker here might be important but please let me know how it affects this if you can.
So our Flask app send some celery tasks with mytask.apply_async((args, args), time_limit=5)
. On the other side I have some workers subscribing to a queue task_routes = {'tasks.mytask': {'queue': 'transformations'}}
I ve read in the Celery docs that the queue is created when a celery worker starts and subscribes to it. So there are a few things here which I can find answers in documentation:
Ok I found some usefull resources: