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

add workflow 天润dynamic邮件同步,dev

This commit is contained in:
root 2025-12-03 12:01:23 +08:00
parent 4087aacfc6
commit 6be75c1e8d
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
dev/workflow/TK_Cust/smart_ccc_dynamic_email/天润dynamic邮件同步/wf_dag_smart_ccc_dynamic_email.py
View File

@ -24,10 +24,12 @@ default_args = {
} }
dag = DAG('wf_dag_smart_ccc_dynamic_email', default_args=default_args, dag = DAG('wf_dag_smart_ccc_dynamic_email', default_args=default_args,
schedule_interval="5 10,14,18,16 * * *", schedule_interval="5,35 9-18 * * *",
catchup=False, catchup=False,
dagrun_timeout=timedelta(minutes=160), dagrun_timeout=timedelta(minutes=600),
max_active_runs=3) max_active_runs=3,
tags=['64cbd1bbced14209b5e3a879f89e8ab1','TK_Cust','天润dynamic邮件同步']
)
task_failed = EmailOperator ( task_failed = EmailOperator (
dag=dag, dag=dag,
@ -42,7 +44,7 @@ task_failed = EmailOperator (
dysql_update_dynamic_email_data = SSHOperator( dysql_update_dynamic_email_data = SSHOperator(
ssh_hook=sshHook, ssh_hook=sshHook,
task_id='dysql_update_dynamic_email_data', task_id='dysql_update_dynamic_email_data',
command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}} >>/data/airflow/logs/run_tpt_{{ds_nodash}}.log 2>&1 ', command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}} ',
params={'my_param':"dysql_update_dynamic_email_data"}, params={'my_param':"dysql_update_dynamic_email_data"},
depends_on_past=False, depends_on_past=False,
retries=3, retries=3,
@ -63,7 +65,7 @@ dag=dag)
f_ccc_work_ticket_integ = SSHOperator( f_ccc_work_ticket_integ = SSHOperator(
ssh_hook=sshHook, ssh_hook=sshHook,
task_id='f_ccc_work_ticket_integ', task_id='f_ccc_work_ticket_integ',
command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}} >>/data/airflow/logs/run_tpt_{{ds_nodash}}.log 2>&1 ', command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}} ',
params={'my_param':"f_ccc_work_ticket_integ_agi"}, params={'my_param':"f_ccc_work_ticket_integ_agi"},
depends_on_past=False, depends_on_past=False,
retries=3, retries=3,