Fix: use correct queue name for scheduled queries

This commit is contained in:
Arik Fraimovich 2014-08-04 22:31:13 +03:00
parent b1e1a32f37
commit 4c28d11259

View File

@ -68,9 +68,9 @@ class QueryTask(object):
pipe.multi()
if scheduled:
queue_name = data_source.queue_name
else:
queue_name = data_source.scheduled_queue_name
else:
queue_name = data_source.queue_name
result = execute_query.apply_async(args=(query, data_source.id), queue=queue_name)
job = cls(async_result=result)