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

add workflow 简道云销售拜访数据同步,dev

This commit is contained in:
root 2025-09-26 16:28:09 +08:00
parent 7969b2e3e3
commit 6c706a605b
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
dev/workflow/TK_Cust/jdy_account_vist_syncs/简道云销售拜访数据同步/wf_dag_jdy_account_vist_syncs.py
View File

@ -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