From 59e74b80b70bf2633ca9f9f55bde639424097025 Mon Sep 17 00:00:00 2001 From: root Date: Fri, 21 Nov 2025 15:58:09 +0800 Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E5=B8=82=E5=9C=BA-Agents?= =?UTF-8?q?=E8=B0=83=E5=BA=A6,dev?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../wf_dag_agents_market_newsletter.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/dev/workflow/TK_Cust/agents_market_newsletter/市场-Agents调度/wf_dag_agents_market_newsletter.py b/dev/workflow/TK_Cust/agents_market_newsletter/市场-Agents调度/wf_dag_agents_market_newsletter.py index 04e82ed..5ced71c 100644 --- a/dev/workflow/TK_Cust/agents_market_newsletter/市场-Agents调度/wf_dag_agents_market_newsletter.py +++ b/dev/workflow/TK_Cust/agents_market_newsletter/市场-Agents调度/wf_dag_agents_market_newsletter.py @@ -26,7 +26,7 @@ default_args = { dag = DAG('wf_dag_agents_market_newsletter', default_args=default_args, schedule_interval="0 18 * * 5", catchup=False, -dagrun_timeout=timedelta(minutes=160), +dagrun_timeout=timedelta(minutes=1440), max_active_runs=3, tags=['64cbd1bbced14209b5e3a879f89e8ab1','TK_Cust','市场-Agents调度'] ) @@ -39,7 +39,7 @@ task_failed = EmailOperator ( cc=[""], subject="agents_market_newsletter_failed", html_content='

您好,agents_market_newsletter作业失败,请及时处理"

') - + agents_recuriments = SSHOperator( ssh_hook=sshHook, @@ -49,7 +49,7 @@ params={'my_param':"agents_recuriments"}, depends_on_past=False, retries=1, dag=dag) - + agents_market_summar = SSHOperator( ssh_hook=sshHook, @@ -59,7 +59,7 @@ params={'my_param':"agents_market_summar"}, depends_on_past=False, retries=1, dag=dag) - + tk_product_prefer = SSHOperator( ssh_hook=sshHook, @@ -69,7 +69,7 @@ params={'my_param':"tk_product_prefer"}, depends_on_past=False, retries=1, dag=dag) - -agents_market_summar >> tk_product_prefer -agents_recuriments >> tk_product_prefer -tk_product_prefer >> task_failed + +agents_market_summar >> tk_product_prefer +agents_recuriments >> tk_product_prefer +tk_product_prefer >> task_failed