From 6c706a605be4188f5c0426bfaf438ac4893567e3 Mon Sep 17 00:00:00 2001 From: root Date: Fri, 26 Sep 2025 16:28:09 +0800 Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E7=AE=80=E9=81=93=E4=BA=91?= =?UTF-8?q?=E9=94=80=E5=94=AE=E6=8B=9C=E8=AE=BF=E6=95=B0=E6=8D=AE=E5=90=8C?= =?UTF-8?q?=E6=AD=A5,dev?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../wf_dag_jdy_account_vist_syncs.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云销售拜访数据同步/wf_dag_jdy_account_vist_syncs.py b/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云销售拜访数据同步/wf_dag_jdy_account_vist_syncs.py index 1d1c128..bca20e9 100644 --- a/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云销售拜访数据同步/wf_dag_jdy_account_vist_syncs.py +++ b/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云销售拜访数据同步/wf_dag_jdy_account_vist_syncs.py @@ -158,11 +158,11 @@ params={'my_param':"t01_jdy_account_agi"}, depends_on_past=False, retries=3, dag=dag) -t01_s_jdy_ae_plan = SSHOperator( +t01_jdy_ae_plan = SSHOperator( ssh_hook=sshHook, -task_id='t01_s_jdy_ae_plan', +task_id='t01_jdy_ae_plan', 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':"t01_s_jdy_ae_plan_agi"}, +params={'my_param':"t01_jdy_ae_plan_agi"}, depends_on_past=False, retries=3, dag=dag) @@ -174,11 +174,11 @@ params={'my_param':"t01_jdy_contact_agi"}, depends_on_past=False, retries=3, dag=dag) -t01_s_jdy_daily_visit = SSHOperator( +t01_jdy_daily_visit = SSHOperator( ssh_hook=sshHook, -task_id='t01_s_jdy_daily_visit', +task_id='t01_jdy_daily_visit', 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':"t01_s_jdy_daily_visit_agi"}, +params={'my_param':"t01_jdy_daily_visit_agi"}, depends_on_past=False, retries=3, dag=dag) @@ -199,9 +199,9 @@ Jdy_ae_01_load >> jdy_ae_plan_2600 Jdy_daily_visit_load >> jdy_daily_visit_9783 Jdy_account_01_load >> jdy_account_4319 jdy_account_4319 >> t01_jdy_account -jdy_ae_plan_2600 >> t01_s_jdy_ae_plan +jdy_ae_plan_2600 >> t01_jdy_ae_plan jdy_contact_6445 >> t01_jdy_contact -jdy_daily_visit_9783 >> t01_s_jdy_daily_visit +jdy_daily_visit_9783 >> t01_jdy_daily_visit jdy_ae_plan_2600 >> dysql_tk_jdy_employee jdy_contact_6445 >> dysql_tk_jdy_employee jdy_daily_visit_9783 >> dysql_tk_jdy_employee