From fc995df1184210940a0e1c73c9069a996a73febd Mon Sep 17 00:00:00 2001
From: Vincent <vincent.chery@m4x.org>
Date: Wed, 31 Jul 2024 14:39:03 +0200
Subject: [PATCH 1/2] Update logbook flow schedule

---
 datascience/src/pipeline/flows_config.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/datascience/src/pipeline/flows_config.py b/datascience/src/pipeline/flows_config.py
index 1768a7ae49..e25acf3dc1 100644
--- a/datascience/src/pipeline/flows_config.py
+++ b/datascience/src/pipeline/flows_config.py
@@ -88,7 +88,6 @@
         ),
     ]
 )
-logbook.flow.schedule = CronSchedule("* * * * *")
 enrich_logbook.flow.schedule = Schedule(
     clocks=[
         clocks.CronClock(
@@ -130,6 +129,7 @@
         )
     ]
 )
+logbook.flow.schedule = CronSchedule("0,5,10,15,20,25,30,35,40,45,50,55 * * * *")
 missing_far_alerts.flow.schedule = Schedule(
     clocks=[
         clocks.CronClock(

From 7c67cb42c23bc7b3cfbd908ee6b46125d52e0616 Mon Sep 17 00:00:00 2001
From: Vincent <vincent.chery@m4x.org>
Date: Wed, 31 Jul 2024 14:45:35 +0200
Subject: [PATCH 2/2] Update flows schedules

---
 datascience/src/pipeline/flows_config.py | 20 ++++++++++----------
 1 file changed, 10 insertions(+), 10 deletions(-)

diff --git a/datascience/src/pipeline/flows_config.py b/datascience/src/pipeline/flows_config.py
index e25acf3dc1..8c3ac94d58 100644
--- a/datascience/src/pipeline/flows_config.py
+++ b/datascience/src/pipeline/flows_config.py
@@ -74,7 +74,7 @@
 control_anteriority.flow.schedule = CronSchedule("5 * * * *")
 control_units.flow.schedule = CronSchedule("12 8 * * *")
 controls_open_data.flow.schedule = CronSchedule("15 3 * * 5")
-current_segments.flow.schedule = CronSchedule("2,12,22,32,42,52 * * * *")
+current_segments.flow.schedule = CronSchedule("2,22,42 * * * *")
 distribute_pnos.flow.schedule = Schedule(
     clocks=[
         clocks.CronClock(
@@ -180,7 +180,7 @@
         ),
     ]
 )
-update_beacon_malfunctions.flow.schedule = CronSchedule("5,15,25,35,45,55 * * * *")
+update_beacon_malfunctions.flow.schedule = CronSchedule("6,16,26,36,46,56 * * * *")
 position_alerts.flow.schedule = Schedule(
     clocks=[
         clocks.CronClock(
@@ -196,7 +196,7 @@
             },
         ),
         clocks.CronClock(
-            "2,12,22,32,42,52 * * * *",
+            "3,13,23,33,43,53 * * * *",
             parameter_defaults={
                 "alert_type": "FRENCH_EEZ_FISHING_ALERT",
                 "alert_config_name": "FRENCH_EEZ_FISHING_ALERT",
@@ -213,7 +213,7 @@
             },
         ),
         clocks.CronClock(
-            "3,13,23,33,43,53 * * * *",
+            "5,15,25,35,45,55 * * * *",
             parameter_defaults={
                 "alert_type": "TWELVE_MILES_FISHING_ALERT",
                 "alert_config_name": "TWELVE_MILES_FISHING_ALERT_BE_NL",
@@ -224,7 +224,7 @@
             },
         ),
         clocks.CronClock(
-            "4,14,24,34,44,54 * * * *",
+            "7,17,27,37,47,57 * * * *",
             parameter_defaults={
                 "alert_type": "TWELVE_MILES_FISHING_ALERT",
                 "alert_config_name": "TWELVE_MILES_FISHING_ALERT_ES",
@@ -235,7 +235,7 @@
             },
         ),
         clocks.CronClock(
-            "5,15,25,35,45,55 * * * *",
+            "8,18,28,38,48,58 * * * *",
             parameter_defaults={
                 "alert_type": "TWELVE_MILES_FISHING_ALERT",
                 "alert_config_name": "TWELVE_MILES_FISHING_ALERT_DE",
@@ -246,7 +246,7 @@
             },
         ),
         clocks.CronClock(
-            "6,16,26,36,46,56 * * * *",
+            "9,19,29,39,49,59 * * * *",
             parameter_defaults={
                 "alert_type": "TWELVE_MILES_FISHING_ALERT",
                 "alert_config_name": "TWELVE_MILES_FISHING_ALERT_OTHERS",
@@ -268,10 +268,10 @@
         ),
     ]
 )
-regulations.flow.schedule = CronSchedule("6,16,26,36,46,56 * * * *")
+regulations.flow.schedule = CronSchedule("2,32 * * * *")
 regulations_checkup.flow.schedule = CronSchedule("5 6 * * 1,2,3,4,5")
 regulations_open_data.flow.schedule = CronSchedule("18 1 * * 5")
-risk_factor.flow.schedule = CronSchedule("3,13,23,33,43,53 * * * *")
+risk_factor.flow.schedule = CronSchedule("3,23,43 * * * *")
 scrape_legipeche.flow.schedule = CronSchedule("15 5 * * 1,2,3,4,5")
 validate_pending_alerts.flow.schedule = Schedule(
     clocks=[
@@ -283,7 +283,7 @@
         ),
     ]
 )
-vessels.flow.schedule = CronSchedule("5 2,5,8,11,14,17,20,23 * * *")
+vessels.flow.schedule = CronSchedule("2 2,5,8,11,14,17,20,23 * * *")
 
 
 ###################### List flows to register with prefect server #####################