From 4dca7cfa74cdd0ed7fe2a333d0c63e3cad09e3f2 Mon Sep 17 00:00:00 2001 From: root Date: Thu, 15 Aug 2024 14:18:43 +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 | 11 +---------- 1 file changed, 1 insertion(+), 10 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 50febfa..73415d6 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 @@ -83,17 +83,8 @@ params={'my_param':"t01_ccc_work_ticket_info_agi"}, depends_on_past=False, retries=3, 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 ', -params={'my_param':"f_ccc_work_ticket_integ_agi"}, -depends_on_past=False, -retries=3, -dag=dag) tickets_list_load >> tr_ticket_list_4585 tickets_list_load >> tr_ticket_detail_4125 tr_ticket_list_4585 >> t01_ccc_work_ticket_info tr_ticket_detail_4125 >> t01_ccc_work_ticket_info -t01_ccc_work_ticket_info >> f_ccc_work_ticket_integ -f_ccc_work_ticket_integ >> task_failed +t01_ccc_work_ticket_info >> task_failed