From 729092f3fa1c1b82bcd4d40c3a97b014e8f407ef Mon Sep 17 00:00:00 2001
From: root <root@64792e78fd4d>
Date: Mon, 29 Sep 2025 14:37:48 +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

---
 .../天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py  | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

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 53e99ff..07dd9ba 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
@@ -110,8 +110,17 @@ params={'my_param':"t01_ccc_cust_info_agi"},
 depends_on_past=False, 
 retries=3, 
 dag=dag)
+d_ccc_cust_info = SSHOperator(
+ssh_hook=sshHook,
+task_id='d_ccc_cust_info',
+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':"d_ccc_cust_info_agi"},
+depends_on_past=False, 
+retries=3, 
+dag=dag)
 customer_labels_load >> tr_custom_labels_8280
 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 
+t01_ccc_cust_info >> d_ccc_cust_info
+d_ccc_cust_info >> task_failed