From 823ca0c51b814485b047e3752997af020b46e596 Mon Sep 17 00:00:00 2001 From: Matt Bone Date: Thu, 21 Apr 2016 16:31:34 -0500 Subject: [PATCH] allow scheduler to schedule all pending tasks --- django_q/cluster.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/django_q/cluster.py b/django_q/cluster.py index 33ee040b..877543bc 100644 --- a/django_q/cluster.py +++ b/django_q/cluster.py @@ -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