KnowledgeHub
Questions
Tags
Users
Search
Alex Rivera
|
Logout
Edit Question
Title
Body
I'm trying to call a task and create a queue for that task if it doesn't exist then immediately insert to that queue the called task. I have the following code: @task def greet(name): return "Hello %s!" % name def run(): result = greet.delay(args=['marc'], queue='greet.1', routing_key='greet.1') print result.ready() then I have a custom router: class MyRouter(object): def route_for_task(self, task, args=None, kwargs=None): if task == 'tasks.greet': return {'queue': kwargs['queue'], 'exchange': 'greet', 'exchange_type': 'direct', 'routing_key': kwargs['routing_key']} return None this creates an exchange called greet.1 and a queue called greet.1 but the queue is empty. The exchange should be just called greet which knows how to route a routing key like greet.1 to the queue called greet.1 . Any ideas?
Tags (comma-separated)
Save Edits
Cancel