Also fetches name override from q_options

This commit is contained in:
Ilan Steemers
2016-02-28 15:11:48 +01:00
parent 1e5509de45
commit d4e0646097
+1 -1
View File
@@ -19,7 +19,7 @@ def async(func, *args, **kwargs):
"""Queue a task for the cluster."""
keywords = kwargs.copy()
opt_keys = ('hook', 'group', 'save', 'sync', 'cached', 'iter_count', 'iter_cached', 'chain', 'broker')
q_options = keywords.pop('q_options', None)
q_options = keywords.pop('q_options', {})
# get an id
tag = uuid()
# build the task package