From d0d6f2f54baf8fd60c8939439d702e7d89e462ef Mon Sep 17 00:00:00 2001 From: root Date: Tue, 18 Feb 2025 16:19:26 +0800 Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E5=A4=A9=E6=B6=A6Smart-ccc?= =?UTF-8?q?=E4=BC=9A=E8=AF=9D=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_chat.py | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/dev/workflow/TK_Cust/smart_ccc_chat/天润Smart-ccc会话数据/wf_dag_smart_ccc_chat.py b/dev/workflow/TK_Cust/smart_ccc_chat/天润Smart-ccc会话数据/wf_dag_smart_ccc_chat.py index 8058ecc..05ea719 100644 --- a/dev/workflow/TK_Cust/smart_ccc_chat/天润Smart-ccc会话数据/wf_dag_smart_ccc_chat.py +++ b/dev/workflow/TK_Cust/smart_ccc_chat/天润Smart-ccc会话数据/wf_dag_smart_ccc_chat.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_chat', default_args=default_args, -schedule_interval="0 0-23/1 * * *", +schedule_interval="0 8 * * *", 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_chat_failed", html_content='

您好，smart_ccc_chat作业失败，请及时处理"

') @@ -199,4 +199,6 @@ cust_leads >> cust_all_info cust_contact_info >> cust_all_info chat_records_n_load >> tr_chat_messages_new_2443 chat_records_n_load >> tr_chat_records_new_9594 -tr_chat_records_new_9594 >> task_failed +tr_chat_messages_new_2443 >> t01_ccc_chat_message_detail +tr_chat_records_new_9594 >> t01_ccc_chat_record +t01_ccc_chat_record >> task_failed