From 40a1fff847f37cf78578970f56711390e8c88179 Mon Sep 17 00:00:00 2001 From: root Date: Mon, 8 Dec 2025 16:47:13 +0800 Subject: [PATCH] =?UTF-8?q?add=20workflow=20Append-=E5=AE=A2=E6=88=B7?= =?UTF-8?q?=E4=BF=A1=E6=81=AF=E8=A1=A5=E5=85=A8,dev?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Append-客户信息补全/wf_dag_account_complete_append.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/dev/workflow/TK_Cust/account_complete_append/Append-客户信息补全/wf_dag_account_complete_append.py b/dev/workflow/TK_Cust/account_complete_append/Append-客户信息补全/wf_dag_account_complete_append.py index 10135a0..937d85d 100644 --- a/dev/workflow/TK_Cust/account_complete_append/Append-客户信息补全/wf_dag_account_complete_append.py +++ b/dev/workflow/TK_Cust/account_complete_append/Append-客户信息补全/wf_dag_account_complete_append.py @@ -39,9 +39,9 @@ task_failed = EmailOperator ( cc=[""], subject="account_complete_append_failed", html_content='

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

') - -156_account_complete_append = SSHOperator( + +account_complete_append = SSHOperator( ssh_hook=sshHook, task_id='156_account_complete_append', command='cd /data/airflow/etl/agents && python 156_account_complete_append.py', @@ -49,5 +49,5 @@ params={'my_param':"156_account_complete_append"}, depends_on_past=False, retries=1, dag=dag) - -156_account_complete_append >> task_failed + +account_complete_append >> task_failed