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

add workflow 天润Smart-ccc客户数据,dev

This commit is contained in:
root 2025-09-29 14:37:48 +08:00
parent 05ec7d92ff
commit 729092f3fa
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据/wf_dag_smart_ccc_custom.py
View File

@ -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