Parcourir la source

feat:添加分析任务

zhaohaipeng il y a 10 mois
Parent
commit
1b0f230377
1 fichiers modifiés avec 1 ajouts et 1 suppressions
  1. 1 1
      feature_spark_monitor.py

+ 1 - 1
feature_spark_monitor.py

@@ -126,7 +126,7 @@ def _main():
         b, latest_started_time = handle_table(table_name, result)
         if b:
             print(f"表: {table_name}, 最后一次同步时间距当前时间超过140分钟")
-            send_error_info(table_name, latest_started_time, webhook_url)
+            # send_error_info(table_name, latest_started_time, webhook_url)
 
 
 if __name__ == '__main__':