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