update to schedules

Author: ohld

flow_deployments/broadcasts.py

@@ -33,7 +33,7 @@
 deployment_broadcast_1w_ago = Deployment.build_from_flow(
     flow=broadcast_next_meme_to_active_1w_ago,
     name="broadcast_next_meme_to_active_1w_ago",
-    schedule=(CronSchedule(cron="7 * * * *", timezone="Europe/London")),
+    schedules=[CronSchedule(cron="7 * * * *", timezone="Europe/London")],
     work_pool_name=settings.ENVIRONMENT,
 )
 
@@ -43,7 +43,7 @@
 deployment_broadcast_4w_ago = Deployment.build_from_flow(
     flow=broadcast_next_meme_to_active_4w_ago,
     name="broadcast_next_meme_to_active_4w_ago",
-    schedule=(CronSchedule(cron="9 * * * *", timezone="Europe/London")),
+    schedules=[CronSchedule(cron="9 * * * *", timezone="Europe/London")],
     work_pool_name=settings.ENVIRONMENT,
 )
 

flow_deployments/crossposting.py

@@ -10,7 +10,7 @@
 deployment_crossposting_tgchannelen = Deployment.build_from_flow(
     flow=post_meme_to_tgchannelen,
     name="post_meme_to_tgchannelen",
-    schedule=(CronSchedule(cron="3 */5 * * *", timezone="Europe/London")),
+    schedules=[CronSchedule(cron="3 */5 * * *", timezone="Europe/London")],
     work_pool_name=settings.ENVIRONMENT,
 )
 
@@ -20,7 +20,7 @@
 deployment_crossposting_tgchannelru = Deployment.build_from_flow(
     flow=post_meme_to_tgchannelru,
     name="post_meme_to_tgchannelru",
-    schedule=(CronSchedule(cron="33 */5 * * *", timezone="Europe/London")),
+    schedules=[CronSchedule(cron="33 */5 * * *", timezone="Europe/London")],
     work_pool_name=settings.ENVIRONMENT,
 )
 

flow_deployments/parsers.py

@@ -9,7 +9,7 @@
 deployment_tg = Deployment.build_from_flow(
     flow=parse_telegram_sources,
     name="Parse Telegram Sources",
-    schedule=(CronSchedule(cron="0 * * * *", timezone="Europe/London")),
+    schedules=[CronSchedule(cron="0 * * * *", timezone="Europe/London")],
     work_pool_name=settings.ENVIRONMENT,
 )
 
@@ -20,7 +20,7 @@
     flow=parse_vk_sources,
     name="Parse VK Sources",
     work_pool_name=settings.ENVIRONMENT,
-    schedule=(CronSchedule(cron="20 * * * *", timezone="Europe/London")),
+    schedules=[CronSchedule(cron="20 * * * *", timezone="Europe/London")],
 )
 
 deployment_vk.apply()
@@ -30,7 +30,7 @@
     flow=parse_ig_sources,
     name="Parse Instgram Sources",
     work_pool_name=settings.ENVIRONMENT,
-    schedule=(CronSchedule(cron="30 */5 * * *", timezone="Europe/London")),
+    schedules=[CronSchedule(cron="30 */5 * * *", timezone="Europe/London")],
 )
 
 deployment_ig.apply()

flow_deployments/stats.py

@@ -11,7 +11,7 @@
     flow=calculate_user_stats,
     name="Calculate user_stats",
     work_pool_name=settings.ENVIRONMENT,
-    schedule=(CronSchedule(cron="0,15,30,45 * * * *", timezone="Europe/London")),
+    schedules=[CronSchedule(cron="0,2,15,30,45 * * * *", timezone="Europe/London")],
 )
 
 deployment_user_stats.apply()
@@ -21,7 +21,11 @@
     flow=calculate_user_meme_source_stats,
     name="Calculate user_meme_source_stats",
     work_pool_name=settings.ENVIRONMENT,
-    schedule=(CronSchedule(cron="13,28,43,58 * * * *", timezone="Europe/London")),
+    schedules=[
+        CronSchedule(
+            cron="3,8,13,18,23,28,33,38,43,48,53,58 * * * *", timezone="Europe/London"
+        )
+    ],
 )
 
 deployment_user_meme_source_stats.apply()
@@ -31,7 +35,7 @@
     flow=calculate_meme_stats,
     name="Calculate meme_stats",
     work_pool_name=settings.ENVIRONMENT,
-    schedule=(CronSchedule(cron="3,18,33,48 * * * *", timezone="Europe/London")),
+    schedules=[CronSchedule(cron="3,18,33,48 * * * *", timezone="Europe/London")],
 )
 
 deployment_user_stats.apply()
@@ -41,7 +45,7 @@
     flow=calculate_meme_source_stats,
     name="Calculate meme_source_stats",
     work_pool_name=settings.ENVIRONMENT,
-    schedule=(CronSchedule(cron="5,20,35,50 * * * *", timezone="Europe/London")),
+    schedules=[CronSchedule(cron="5,20,35,50 * * * *", timezone="Europe/London")],
 )
 
 deployment_meme_source_stats.apply()

flow_deployments/storage.py

@@ -7,7 +7,7 @@
 deployment_ocr_uploaded_memes = Deployment.build_from_flow(
     flow=ocr_uploaded_memes,
     name="OCR Uploaded Memes",
-    schedule=(CronSchedule(cron="*/5 * * * *", timezone="Europe/London")),
+    schedules=[CronSchedule(cron="*/5 * * * *", timezone="Europe/London")],
     work_pool_name=settings.ENVIRONMENT,
 )