You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
However when I try to launch a worker listening only on queue celery:1 for example I get nothing. I realized later that all task are going to celery queue. If I print celery_app.current_task.request.delivery_info in the worker I can see they all are using right priority but routing_key is always celery never celery:2 for example. Here is an example of what I got:
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
From what I get reading this doc https://docs.celeryq.dev/en/stable/userguide/routing.html#redis-message-priorities It sounds like using 4 different priorities (0,1,2,3) I should be able to listen in queue (celery,celery:0,celery:1,celery2) with this configuration:
However when I try to launch a worker listening only on queue celery:1 for example I get nothing. I realized later that all task are going to celery queue. If I print
celery_app.current_task.request.delivery_info
in the worker I can see they all are using right priority but routing_key is always celery never celery:2 for example. Here is an example of what I got:Am I missing something?
Beta Was this translation helpful? Give feedback.
All reactions