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-07-31 14:27:50 +08:00
parent f3dde159ff
commit f4b5afc24c
1 changed files with 0 additions and 20 deletions
dev/workflow/TK_Cust/smart_ccc_custom/天润Smart-ccc客户数据
wf_dag_smart_ccc_custom.py

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

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