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

add workflow 荟聚API_2,dev

This commit is contained in:
root 2024-04-18 16:14:24 +08:00
parent e8eb21ad73
commit 342a62adc5
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
dev/workflow/TK_Cust/tk_api_2/荟聚API_2/wf_dag_tk_api_2.py
View File

@ -149,8 +149,19 @@ depends_on_past=False,
retries=3,
dag=dag)
t01_scrm_leads = SSHOperator(
ssh_hook=sshHook,
task_id='t01_scrm_leads',
command='/data/airflow/etl/PDM/run_sa.sh {{ ds_nodash }} {{params.my_param}} >>/data/airflow/logs/run_tpt_{{ds_nodash}}.log 2>&1 ',
params={'my_param':"t01_scrm_leads_agi"},
depends_on_past=False,
retries=3,
dag=dag)
customer_events_3292 >> customer_events_feign
customer_events_open_content_page_9684 >> custom_events_open_content_page_feign
customer_event_meta_2268 >> customer_event_meta_feign
customer_events_open_page_7519 >> custom_events_open_page_feign
custom_events_open_page_load >> task_failed
custom_events_open_content_page_load >> t01_scrm_leads
customer_event_meta_load >> t01_scrm_leads
custom_events_open_page_load >> t01_scrm_leads
t01_scrm_leads >> task_failed