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-02-06 18:25:11 +08:00
parent 0a2c7254fa
commit 38869ec740
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
dev/workflow/TK_Cust/smart_ccc_ticket/天润Smart-ccc工单数据/wf_dag_smart_ccc_ticket.py
View File

@ -83,8 +83,17 @@ params={'my_param':"t01_ccc_work_ticket_info_agi"},
depends_on_past=False, depends_on_past=False,
retries=3, retries=3,
dag=dag) dag=dag)
t00_china_city_pnum_his = SSHOperator(
ssh_hook=sshHook,
task_id='t00_china_city_pnum_his',
command='/data/airflow/etl/PDM/run_psql.sh {{ ds_nodash }} {{params.my_param}} >>/data/airflow/logs/run_tpt_{{ds_nodash}}.log 2>&1 ',
params={'my_param':"t00_china_city_pnum_his_agi"},
depends_on_past=False,
retries=3,
dag=dag)
tickets_list_load >> tr_ticket_list_4585 tickets_list_load >> tr_ticket_list_4585
tickets_list_load >> tr_ticket_detail_4125 tickets_list_load >> tr_ticket_detail_4125
tr_ticket_list_4585 >> t01_ccc_work_ticket_info tr_ticket_list_4585 >> t01_ccc_work_ticket_info
tr_ticket_detail_4125 >> t01_ccc_work_ticket_info tr_ticket_detail_4125 >> t01_ccc_work_ticket_info
t01_ccc_work_ticket_info >> task_failed t01_ccc_work_ticket_info >> task_failed
t00_china_city_pnum_his >> task_failed