From 6993b9c1914c9046a1ecfa60848d2b93d276b391 Mon Sep 17 00:00:00 2001 From: root Date: Tue, 8 Apr 2025 10:19:54 +0800 Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E5=A4=A9=E6=B6=A6Smart-ccc?= =?UTF-8?q?=E5=B7=A5=E5=8D=95=E6=95=B0=E6=8D=AE,dev?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../天润Smart-ccc工单数据/wf_dag_smart_ccc_ticket.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/dev/workflow/TK_Cust/smart_ccc_ticket/天润Smart-ccc工单数据/wf_dag_smart_ccc_ticket.py b/dev/workflow/TK_Cust/smart_ccc_ticket/天润Smart-ccc工单数据/wf_dag_smart_ccc_ticket.py index f672110..05d89f8 100644 --- a/dev/workflow/TK_Cust/smart_ccc_ticket/天润Smart-ccc工单数据/wf_dag_smart_ccc_ticket.py +++ b/dev/workflow/TK_Cust/smart_ccc_ticket/天润Smart-ccc工单数据/wf_dag_smart_ccc_ticket.py @@ -14,7 +14,7 @@ from airflow.utils.trigger_rule import TriggerRule sshHook = SSHHook(ssh_conn_id ='ssh_air') default_args = { -'owner': 'info@idgvalue.com', +'owner': 'tek_newsletter@163.com', 'email_on_failure': True, 'email_on_retry':True, 'start_date': datetime(2024, 1, 1), @@ -24,7 +24,7 @@ default_args = { } dag = DAG('wf_dag_smart_ccc_ticket', default_args=default_args, -schedule_interval="0 0-23/1 * * *", +schedule_interval="0,30 0-23/1 * * *", catchup=False, dagrun_timeout=timedelta(minutes=160), max_active_runs=3) @@ -33,7 +33,7 @@ task_failed = EmailOperator ( dag=dag, trigger_rule=TriggerRule.ONE_FAILED, task_id="task_failed", - to=["info@idgvalue.com"], + to=["tek_newsletter@163.com"], cc=[""], subject="smart_ccc_ticket_failed", html_content='

您好,smart_ccc_ticket作业失败,请及时处理"

')