allow scheduler to schedule all pending tasks

This commit is contained in:
Matt Bone
2016-04-21 16:31:34 -05:00
parent 4e8a034d80
commit 823ca0c51b

View File

@@ -544,7 +544,8 @@ def scheduler(broker=None):
# default behavior is to delete a ONCE schedule
if s.schedule_type == s.ONCE:
if s.repeats < 0:
return s.delete()
s.delete()
continue
# but not if it has a positive repeats
s.repeats = 0
# save the schedule