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 2024-08-06 16:30:11 +08:00
parent fc38b1230c
commit 3df6382c63
1 changed files with 3 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -47,16 +47,9 @@ depends_on_past=False,
retries=3, retries=3,
dag=dag) dag=dag)
customer_list_load = SSHOperator(
ssh_hook=sshHook,
task_id='customer_list_load',
command='/data/airflow/etl/API/run_psql.sh {{ ds_nodash }} {{params.my_param }}',
params={'my_param':"customer_list_load"},
depends_on_past=False,
retries=3,
dag=dag)
customer_list_feign >> customer_list_load
customer_labels_feign = SSHOperator( customer_labels_feign = SSHOperator(
ssh_hook=sshHook, ssh_hook=sshHook,
@ -178,7 +171,7 @@ depends_on_past=False,
retries=3, retries=3,
dag=dag) dag=dag)
customer_labels_load >> tr_custom_labels_8280 customer_labels_load >> tr_custom_labels_8280
customer_list_load >> tr_custom_details_5516 customer_list_feign >> tr_custom_details_5516
tr_custom_labels_8280 >> t01_ccc_cust_label tr_custom_labels_8280 >> t01_ccc_cust_label
tr_custom_details_5516 >> t01_ccc_cust_info tr_custom_details_5516 >> t01_ccc_cust_info
t01_ccc_cust_label >> dysql_ccc_scrm_cust_label_info t01_ccc_cust_label >> dysql_ccc_scrm_cust_label_info