adds timeout to group_key cache object

This commit is contained in:
Ilan Steemers
2015-10-19 15:42:05 +02:00
parent 37b41b15b1
commit 69551793c0
+1 -1
View File
@@ -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)