Merge pull request #98 from Koed00/dev

Adds timeout to group key cache object
This commit is contained in:
Ilan Steemers
2015-10-20 21:53:52 +02:00
2 changed files with 2 additions and 2 deletions
+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)