dtgitea
/
dataops
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add workflow Append-客户信息补全,dev

This commit is contained in:
root 2025-12-08 16:47:13 +08:00
parent b2fef01101
commit 40a1fff847
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
dev/workflow/TK_Cust/account_complete_append/Append-客户信息补全/wf_dag_account_complete_append.py
View File

@ -39,9 +39,9 @@ task_failed = EmailOperator (
cc=[""], cc=[""],
subject="account_complete_append_failed", subject="account_complete_append_failed",
html_content='<h3>您好，account_complete_append作业失败，请及时处理" </h3>') html_content='<h3>您好，account_complete_append作业失败，请及时处理" </h3>')
156_account_complete_append = SSHOperator(
account_complete_append = SSHOperator(
ssh_hook=sshHook, ssh_hook=sshHook,
task_id='156_account_complete_append', task_id='156_account_complete_append',
command='cd /data/airflow/etl/agents && python 156_account_complete_append.py', 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, depends_on_past=False,
retries=1, retries=1,
dag=dag) dag=dag)
156_account_complete_append >> task_failed account_complete_append >> task_failed