From f4b5afc24cb94612fadfcca956272bddafc4ea41 Mon Sep 17 00:00:00 2001 From: root Date: Wed, 31 Jul 2024 14:27:50 +0800 Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E5=A4=A9=E6=B6=A6Smart-ccc?= =?UTF-8?q?=E5=AE=A2=E6=88=B7=E6=95=B0=E6=8D=AE,dev?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../wf_dag_smart_ccc_custom.py | 20 ------------------- 1 file changed, 20 deletions(-) diff --git a/dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py b/dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py index 1997f3a..3383ce2 100644 --- a/dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py +++ b/dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py @@ -94,25 +94,6 @@ depends_on_past=False, retries=3, dag=dag) -customer_detail_feign = SSHOperator( -ssh_hook=sshHook, -task_id='customer_detail_feign', -command='python3 /data/airflow/etl/API/customer_detail_feign.py', -depends_on_past=False, -retries=3, -dag=dag) - -customer_detail_load = SSHOperator( -ssh_hook=sshHook, -task_id='customer_detail_load', -command='/data/airflow/etl/API/run_psql.sh {{ ds_nodash }} {{params.my_param }}', -params={'my_param':"customer_detail_load"}, -depends_on_past=False, -retries=3, -dag=dag) - -customer_detail_feign >> customer_detail_load - t01_ccc_cust_label = SSHOperator( ssh_hook=sshHook, task_id='t01_ccc_cust_label', @@ -134,4 +115,3 @@ customer_list_load >> tr_custom_details_5516 tr_custom_labels_8280 >> t01_ccc_cust_label tr_custom_details_5516 >> t01_ccc_cust_info t01_ccc_cust_info >> task_failed -customer_detail_load >> task_failed