zhaohaipeng пре 1 месец
родитељ
комит
12cb9e44d7
2 измењених фајлова са 4 додато и 4 уклоњено
  1. 2 2
      enums/automation_job.py
  2. 2 2
      monitor/automation_provide_job_monitor.py

+ 2 - 2
enums/automation_job.py

@@ -12,7 +12,7 @@ class AutomationJobCronInfo(Enum):
     channel_image_search_video_all_cate_top = ("channel_image_search_video_all_cate", "top", 9)
     video_decode_accurate_text_top = ("video_decode_accurate_text", "top", 9)
 
-    def __init__(self, crawler_mode, video_source, min_hour):
+    def __init__(self, crawler_mode, video_source, task_start_hour):
         self.crawler_mode = crawler_mode
         self.video_source = video_source
-        self.min_hour = min_hour
+        self.task_start_hour = task_start_hour

+ 2 - 2
monitor/automation_provide_job_monitor.py

@@ -112,13 +112,13 @@ def main():
     # 当天结束时间(23:59:59.999999)
     end_ts = int(datetime.combine(today.date(), time.max).timestamp())
 
-    job_run_state(start_ts, end_ts)
+    # job_run_state(start_ts, end_ts)
 
     current_hour = today.hour
 
     crawler_mode_and_video_source_list = []
     for cron_info in AutomationJobCronInfo:
-        if cron_info.min_hour < current_hour:
+        if current_hour < cron_info.task_start_hour:
             continue
 
         crawler_mode_and_video_source_list.append((cron_info.crawler_mode, cron_info.video_source))