From cc38b7ed2985717aad1fea5aab3e0f2ad9b4de20 Mon Sep 17 00:00:00 2001 From: root Date: Mon, 22 Sep 2025 19:21:52 +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 --- .../Jdy_account_01_feign.py | 2 +- .../Jdy_contact_01_feign.py | 2 +- .../简道云拜访AE排期同步/Jdy_ae_01_feign.py | 2 +- .../Jdy_daily_visit_feign.py | 2 +- .../wf_dag_jdy_account_vist_syncs.py | 31 +------------------ 5 files changed, 5 insertions(+), 34 deletions(-) diff --git a/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云客户Account同步/Jdy_account_01_feign.py b/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云客户Account同步/Jdy_account_01_feign.py index 0f8bc16..919eae8 100644 --- a/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云客户Account同步/Jdy_account_01_feign.py +++ b/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云客户Account同步/Jdy_account_01_feign.py @@ -189,7 +189,7 @@ def main(): APP_ID = params['app_id'] ENTRY_ID = params['entry_id'] - start_dt = get_previous_date(1) + start_dt = get_previous_date(3) end_dt = get_previous_date(0) # 创建客户端 diff --git a/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云客户Contact同步/Jdy_contact_01_feign.py b/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云客户Contact同步/Jdy_contact_01_feign.py index c7dea51..30832ed 100644 --- a/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云客户Contact同步/Jdy_contact_01_feign.py +++ b/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云客户Contact同步/Jdy_contact_01_feign.py @@ -189,7 +189,7 @@ def main(): APP_ID = params['app_id'] ENTRY_ID = params['entry_id'] - start_dt = get_previous_date(1) + start_dt = get_previous_date(3) end_dt = get_previous_date(0) # 创建客户端 diff --git a/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云拜访AE排期同步/Jdy_ae_01_feign.py b/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云拜访AE排期同步/Jdy_ae_01_feign.py index 59c491b..9843dd8 100644 --- a/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云拜访AE排期同步/Jdy_ae_01_feign.py +++ b/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云拜访AE排期同步/Jdy_ae_01_feign.py @@ -189,7 +189,7 @@ def main(): APP_ID = params['app_id'] ENTRY_ID = params['entry_id'] - start_dt = get_previous_date(1) + start_dt = get_previous_date(3) end_dt = get_previous_date(0) # 创建客户端 diff --git a/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云拜访Visit同步/Jdy_daily_visit_feign.py b/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云拜访Visit同步/Jdy_daily_visit_feign.py index a1d566c..fa14be0 100644 --- a/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云拜访Visit同步/Jdy_daily_visit_feign.py +++ b/dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云拜访Visit同步/Jdy_daily_visit_feign.py @@ -189,7 +189,7 @@ def main(): APP_ID = params['app_id'] ENTRY_ID = params['entry_id'] - start_dt = get_previous_date(1) + start_dt = get_previous_date(3) end_dt = get_previous_date(0) # 创建客户端 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 0376afd..514916b 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 @@ -114,34 +114,6 @@ dag=dag) Jdy_account_01_feign >> Jdy_account_01_load -Jdy_calendar_01_feign = SSHOperator( -ssh_hook=sshHook, -task_id='Jdy_calendar_01_feign', -command='python3 /data/airflow/etl/API/Jdy_calendar_01_feign.py', -depends_on_past=False, -retries=3, -dag=dag) - -Jdy_calendar_01_load = SSHOperator( -ssh_hook=sshHook, -task_id='Jdy_calendar_01_load', -command='/data/airflow/etl/API/run_psql.sh {{ ds_nodash }} {{params.my_param }}', -params={'my_param':"Jdy_calendar_01_load"}, -depends_on_past=False, -retries=3, -dag=dag) - -Jdy_calendar_01_feign >> Jdy_calendar_01_load - -jdy_calendar_8832 = SSHOperator( -ssh_hook=sshHook, -task_id='jdy_calendar_8832', -command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} >>/data/airflow/logs/run_psql_{{ds_nodash}}.log 2>&1 ', -params={'my_param':"S98_S_jdy_calendar"}, -depends_on_past=False, -retries=3, -dag=dag) - jdy_account_4319 = SSHOperator( ssh_hook=sshHook, task_id='jdy_account_4319', @@ -182,5 +154,4 @@ Jdy_contact_01_load >> jdy_contact_6445 Jdy_ae_01_load >> jdy_ae_plan_2600 Jdy_daily_visit_load >> jdy_daily_visit_9783 Jdy_account_01_load >> jdy_account_4319 -Jdy_calendar_01_load >> jdy_calendar_8832 -jdy_calendar_8832 >> task_failed +jdy_account_4319 >> task_failed