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
I hope that celery.node can also receive the queue name as a variable argument of the client.createTask() method.
Proposed Behavior
// suggestion 1. pass the queue name as 2nd argument of `createTask` method.consttask=client.createTask('add',{queue: 'math_tasks'})constanswer=awaittask.applyAsync([1,2]).get()// or// suggestion 2. pass the queue name as 3rd argument of `task.applyAsync` method.// This is a little more Python-like, but requires passing an empty argument when no kwargs are present.consttask=client.createTask('add')constanswer=awaittask.applyAsync([1,2],{},{queue: 'math_tasks'}).get()
The text was updated successfully, but these errors were encountered:
Description
Celery can specify the queue name and routing_key manually at the task message.
https://docs.celeryq.dev/en/stable/userguide/routing.html#manual-routing
I hope that celery.node can also receive the queue name as a variable argument of the
client.createTask()
method.The text was updated successfully, but these errors were encountered: