From 600e161f6caa5a194514c4a50700ec5a46dc273f Mon Sep 17 00:00:00 2001 From: Stan Lagun Date: Wed, 27 Mar 2013 21:36:02 +0400 Subject: [PATCH] typo --- conductor/conductor/app.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/conductor/conductor/app.py b/conductor/conductor/app.py index b6eaf2e..0fb1244 100644 --- a/conductor/conductor/app.py +++ b/conductor/conductor/app.py @@ -79,7 +79,7 @@ class ConductorWorkflowService(service.Service): with rabbitmq.RmqClient() as rmq: rmq.declare('tasks', 'tasks') rmq.declare('task-results') - with rmq.open('tasks2') as subscription: + with rmq.open('tasks') as subscription: while True: msg = subscription.get_message() self.tg.add_thread(