Explorar o código

feat:添加分析任务

zhaohaipeng hai 1 ano
pai
achega
3df62630a4
Modificáronse 1 ficheiros con 1 adicións e 1 borrados
  1. 1 1
      feature_spark_monitor.py

+ 1 - 1
feature_spark_monitor.py

@@ -131,7 +131,7 @@ def _main():
         [date_util.str_cover_date(item['startedTime']) for item in result]
     )
 
-    if (early_started_time - datetime.now()) < timedelta(hours=7):
+    if (early_started_time - datetime.now()) < timedelta(hours=3):
         print("任务最开始时间小于六个小时,疑似清理过任务。跳过")
         return