From 69551793c0430e4f64d6a9ffe0c2e3a709ec8f08 Mon Sep 17 00:00:00 2001 From: Ilan Steemers Date: Mon, 19 Oct 2015 15:42:05 +0200 Subject: [PATCH] adds timeout to group_key cache object --- django_q/cluster.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/django_q/cluster.py b/django_q/cluster.py index b5e8d0c..824dbaf 100644 --- a/django_q/cluster.py +++ b/django_q/cluster.py @@ -450,7 +450,7 @@ def save_cached(task, broker): return # save the group list group_list.append(task_key) - broker.cache.set(group_key, group_list) + broker.cache.set(group_key, group_list, timeout) # async next in a chain if task.get('chain', None): tasks.async_chain(task['chain'], group=group, cached=task['cached'], sync=task['sync'], broker=broker)