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