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

add workflow partner1site,dev

This commit is contained in:
root 2025-09-30 16:50:01 +08:00
parent 1a54db3b73
commit ecf384a6ef
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dev/workflow/TK_Cust/partner1site/partner1site/wf_dag_partner1site.py
View File

@ -60,7 +60,7 @@ part_summary_visit_feign >> part_summary_visit_load
partner_summary_visit_9060 = SSHOperator( partner_summary_visit_9060 = SSHOperator(
ssh_hook=sshHook, ssh_hook=sshHook,
task_id='partner_summary_visit_9060', task_id='partner_summary_visit_9060',
command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} >>/data/airflow/logs/run_psql_{{ds_nodash}}.log 2>&1 ', command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} ',
params={'my_param':"S98_S_partner_summary_visit"}, params={'my_param':"S98_S_partner_summary_visit"},
depends_on_past=False, depends_on_past=False,
retries=3, retries=3,
@ -88,7 +88,7 @@ part_summary_report_feign >> part_summary_report_load
partner_summary_report_6257 = SSHOperator( partner_summary_report_6257 = SSHOperator(
ssh_hook=sshHook, ssh_hook=sshHook,
task_id='partner_summary_report_6257', task_id='partner_summary_report_6257',
command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} >>/data/airflow/logs/run_psql_{{ds_nodash}}.log 2>&1 ', command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} ',
params={'my_param':"S98_S_partner_summary_report"}, params={'my_param':"S98_S_partner_summary_report"},
depends_on_past=False, depends_on_past=False,
retries=3, retries=3,