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:26 +08:00
parent 09091f1bac
commit 089366a1ba
1 changed files with 0 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
dev/workflow/TK_Cust/smart_ccc_cdr/天润Smart-ccc通话记录/wf_dag_smart_ccc_cdr.py
View File

@ -131,25 +131,6 @@ depends_on_past=False,
retries=3, retries=3,
dag=dag) dag=dag)
cc_cdr_ob_detail_feign = SSHOperator(
ssh_hook=sshHook,
task_id='cc_cdr_ob_detail_feign',
command='python3 /data/airflow/etl/API/cc_cdr_ob_detail_feign.py',
depends_on_past=False,
retries=3,
dag=dag)
cc_cdr_ob_detail_load = SSHOperator(
ssh_hook=sshHook,
task_id='cc_cdr_ob_detail_load',
command='/data/airflow/etl/API/run_psql.sh {{ ds_nodash }} {{params.my_param }}',
params={'my_param':"cc_cdr_ob_detail_load"},
depends_on_past=False,
retries=3,
dag=dag)
cc_cdr_ob_detail_feign >> cc_cdr_ob_detail_load
t01_ccc_ib_record = SSHOperator( t01_ccc_ib_record = SSHOperator(
ssh_hook=sshHook, ssh_hook=sshHook,
task_id='t01_ccc_ib_record', task_id='t01_ccc_ib_record',
@ -175,4 +156,3 @@ tr_cc_cdr_ib_agent_list_9092 >> t01_ccc_ib_record
tr_cc_cdr_ob_list_4070 >> t01_ccc_ob_record tr_cc_cdr_ob_list_4070 >> t01_ccc_ob_record
tr_cc_cdr_ob_detail_5097 >> t01_ccc_ob_record tr_cc_cdr_ob_detail_5097 >> t01_ccc_ob_record
t01_ccc_ob_record >> task_failed t01_ccc_ob_record >> task_failed
cc_cdr_ob_detail_load >> task_failed