fix cron

SAP · May 23, 2024 · 70284e4 · 70284e4
1 parent 404b150
commit 70284e4
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/scheduler/kubernetes/scheduler.py b/src/scheduler/kubernetes/scheduler.py
@@ -989,6 +989,18 @@ def handle_cron_jobs(self):
 
                 next_trigger = i.get_next(datetime)
 
+                if next_trigger > datetime.now():
+                    # still in future
+                    continue
+
+                # Double-check the next_trigger by selecting the latest last_trigger for the cronjob
+                cursor.execute("""
+                    SELECT last_trigger
+                    FROM cronjob
+                    WHERE id = %s """, [c['id']])
+                last_trigger = cursor.fetchone()
+                i = croniter('%s %s %s %s %s' % (c['minute'], c['hour'], c['day_month'], c['month'], c['day_week']), last_trigger)
+                next_trigger = i.get_next(datetime)
                 if next_trigger > datetime.now():
                     # still in future
                     continue