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