准备把unified_data和unified_summary合并为一个DAG

dags/dag_dataops_unified_data_scheduler.py

@@ -319,8 +319,10 @@ def handle_dag_failure(context):
 with DAG(
     "dag_dataops_unified_data_scheduler", 
     start_date=datetime(2024, 1, 1), 
-    # 修改调度间隔为每15分钟检查一次，以便及时响应执行计划变化
-    schedule_interval="*/10 * * * *",
+    # 修改调度间隔为每10分钟检查一次，以便及时响应执行计划变化
+    # schedule_interval="*/10 * * * *",
+    # 修改调度间隔为每日0点执行一次
+    schedule_interval="0 0 * * *",
     catchup=False,
     default_args={
         'owner': 'airflow',

dags/dag_dataops_unified_prepare_scheduler.py

@@ -542,7 +542,10 @@ def check_execution_plan_file(**kwargs):
 with DAG(
     "dag_dataops_unified_prepare_scheduler",
     start_date=datetime(2024, 1, 1),
-    schedule_interval="*/5 * * * *",  # 每10分钟运行一次，而不是每天
+    # 每10分钟运行一次，而不是每天
+    # schedule_interval="*/5 * * * *",  
+    # 修改调度间隔为每小时执行一次
+    schedule_interval="0 * * * *",
     catchup=False,
     default_args={
         'owner': 'airflow',

dags/dag_dataops_unified_summary_scheduler.py

@@ -315,7 +315,10 @@ def summarize_unified_execution(**kwargs):
 with DAG(
     "dag_dataops_unified_summary_scheduler", 
     start_date=datetime(2024, 1, 1), 
-    schedule_interval="*/10 * * * *",  # 修改为每15分钟执行一次，与data_scheduler保持一致
+    # 修改为每15分钟执行一次，与data_scheduler保持一致
+    # schedule_interval="*/15 * * * *",  
+    # 修改调度间隔为每日0点执行一次
+    schedule_interval="0 0 * * *",
     catchup=False,
     default_args={
         'owner': 'airflow',