Merge pull request #159 from Koed00/dev

Fixes typo in custom broker handler
Koed00 · Apr 7, 2016 · a702408 · a702408
2 parents cbf6fc5 + 6026953
commit a702408
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/django_q/brokers/__init__.py b/django_q/brokers/__init__.py
@@ -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

diff --git a/django_q/cluster.py b/django_q/cluster.py
@@ -399,7 +399,7 @@ def save_task(task, broker):
     Saves the task package to Django or the cache
     """
     # SAVE LIMIT < 0 : Don't save success
-    if not task.get('save', Conf.SAVE_LIMIT > 0) and task['success']:
+    if not task.get('save', Conf.SAVE_LIMIT >= 0) and task['success']:
         return
     # async next in a chain
     if task.get('chain', None):