Makes it possible to set a schedules group name via q_options dict

This commit is contained in:
Ilan Steemers
2016-02-24 11:22:58 +01:00
parent 397503f5b2
commit 763fff34c0
+1 -1
View File
@@ -530,7 +530,7 @@ def scheduler(broker=None):
s.repeats += -1
# send it to the cluster
q_options['broker'] = broker
q_options['group'] = s.name or s.id
q_options['group'] = q_options.get('group', s.name or s.id)
kwargs['q_options'] = q_options
s.task = tasks.async(s.func, *args, **kwargs)
# log it