Fixes typo in custom broker handler

This commit is contained in:
Ilan Steemers
2016-04-06 19:59:02 +02:00
parent cbf6fc5a77
commit 3a57ab1b1b
+1 -1
View File
@@ -163,7 +163,7 @@ def get_broker(list_key=Conf.PREFIX):
module, func = Conf.BROKER_CLASS.rsplit('.', 1)
m = importlib.import_module(module)
broker = getattr(m, func)
return broker(list_key=list)
return broker(list_key=list_key)
# disque
elif Conf.DISQUE_NODES:
from brokers import disque