Merge pull request #165 from thatmattbone/master

allow scheduler to schedule all pending tasks
2026-09-26 19:38:13 +08:00 · 2016-04-24 15:19:02 +02:00
parent 4e8a034d80 823ca0c51b
commit fb3b595e54
1 changed files with 2 additions and 1 deletions
@@ -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