From 6be75c1e8d3383c056b01bccba7b45c512edac82 Mon Sep 17 00:00:00 2001
From: root <root@64792e78fd4d>
Date: Wed, 3 Dec 2025 12:01:23 +0800
Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E5=A4=A9=E6=B6=A6dynamic?=
 =?UTF-8?q?=E9=82=AE=E4=BB=B6=E5=90=8C=E6=AD=A5,dev?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../wf_dag_smart_ccc_dynamic_email.py                | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/dev/workflow/TK_Cust/smart_ccc_dynamic_email/天润dynamic邮件同步/wf_dag_smart_ccc_dynamic_email.py b/dev/workflow/TK_Cust/smart_ccc_dynamic_email/天润dynamic邮件同步/wf_dag_smart_ccc_dynamic_email.py
index 93b2f0e..c9b102b 100644
--- a/dev/workflow/TK_Cust/smart_ccc_dynamic_email/天润dynamic邮件同步/wf_dag_smart_ccc_dynamic_email.py
+++ b/dev/workflow/TK_Cust/smart_ccc_dynamic_email/天润dynamic邮件同步/wf_dag_smart_ccc_dynamic_email.py
@@ -24,10 +24,12 @@ default_args = {
 }
 
 dag = DAG('wf_dag_smart_ccc_dynamic_email', default_args=default_args,
-schedule_interval="5 10,14,18,16 * * *",
+schedule_interval="5,35 9-18 * * *",
 catchup=False,
-dagrun_timeout=timedelta(minutes=160),
-max_active_runs=3)
+dagrun_timeout=timedelta(minutes=600),
+max_active_runs=3,
+tags=['64cbd1bbced14209b5e3a879f89e8ab1','TK_Cust','天润dynamic邮件同步']
+)
 
 task_failed = EmailOperator (
     dag=dag,
@@ -42,7 +44,7 @@ task_failed = EmailOperator (
 dysql_update_dynamic_email_data = SSHOperator(
 ssh_hook=sshHook,
 task_id='dysql_update_dynamic_email_data',
-command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}} >>/data/airflow/logs/run_tpt_{{ds_nodash}}.log 2>&1 ',
+command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}}  ',
 params={'my_param':"dysql_update_dynamic_email_data"},
 depends_on_past=False, 
 retries=3, 
@@ -63,7 +65,7 @@ dag=dag)
 f_ccc_work_ticket_integ = SSHOperator(
 ssh_hook=sshHook,
 task_id='f_ccc_work_ticket_integ',
-command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}} >>/data/airflow/logs/run_tpt_{{ds_nodash}}.log 2>&1 ',
+command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}}  ',
 params={'my_param':"f_ccc_work_ticket_integ_agi"},
 depends_on_past=False, 
 retries=3,