pipeline版本的prepare/data代码修改了手工传参的日志

dags/dag_dataops_pipeline_data_scheduler.py

@@ -889,7 +889,7 @@ with DAG(
         'retry_delay': timedelta(minutes=5)
     },
     params={
-        'MANUAL_TRIGGER': True, 
+        'MANUAL_TRIGGER': False, 
     },
     # 添加DAG级别参数，确保任务运行时有正确的环境
     # params={

dags/dag_dataops_pipeline_prepare_scheduler.py

@@ -399,7 +399,8 @@ def prepare_pipeline_dag_schedule(**kwargs):
     params = kwargs.get('params', {})
     if params and 'MANUAL_TRIGGER' in params:
         is_manual_trigger = params.get('MANUAL_TRIGGER', False)
-        logger.info(f"接收到手动触发参数: MANUAL_TRIGGER={is_manual_trigger}")
+        if is_manual_trigger:
+            logger.info(f"接收到手动触发参数: MANUAL_TRIGGER={is_manual_trigger}")
     
     # 获取执行日期
     dag_run = kwargs.get('dag_run')
@@ -603,7 +604,7 @@ with DAG(
         'retry_delay': timedelta(minutes=5)
     },
     params={
-        'MANUAL_TRIGGER': True, 
+        'MANUAL_TRIGGER': False, 
     },
 ) as dag: