From 04cd1e14abe76dca314d4f055a28dbfb7ca8853c Mon Sep 17 00:00:00 2001
From: root <root@64792e78fd4d>
Date: Tue, 9 Dec 2025 18:19:22 +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               | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

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 b8d22a2..cb0b5b7 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
@@ -90,7 +90,17 @@ depends_on_past=False,
 retries=1, 
 dag=dag)
 
+a_market_Intelligence_newsletter = SSHOperator(
+ssh_hook=sshHook,
+task_id='a_market_Intelligence_newsletter',
+command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}}  ',
+params={'my_param':"a_market_Intelligence_newsletter_agi"},
+depends_on_past=False, 
+retries=3, 
+dag=dag)
 agents_market_summar >> tk_product_prefer
 agents_market_summar >> batch_gen_crawer
 agents_recuriments >> batch_gen_recruiment
-batch_gen_recruiment >> task_failed 
+batch_gen_crawer >> a_market_Intelligence_newsletter
+a_market_Intelligence_newsletter >> tk_product_prefer
+tk_product_prefer >> task_failed