From e4edb0aed945ac0826b4068428bf5e12d8bbf55b Mon Sep 17 00:00:00 2001
From: root <root@64792e78fd4d>
Date: Fri, 27 Feb 2026 10:39:10 +0800
Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E6=8B=9B=E8=81=98=E4=BF=A1?=
 =?UTF-8?q?=E6=81=AF=E5=AF=BC=E5=85=A5,dev?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../招聘信息导入/wf_dag_agent_recruitment.py          | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/dev/workflow/TK_Cust/agent_recruitment/招聘信息导入/wf_dag_agent_recruitment.py b/dev/workflow/TK_Cust/agent_recruitment/招聘信息导入/wf_dag_agent_recruitment.py
index 842bc05..c8c6d40 100644
--- a/dev/workflow/TK_Cust/agent_recruitment/招聘信息导入/wf_dag_agent_recruitment.py
+++ b/dev/workflow/TK_Cust/agent_recruitment/招聘信息导入/wf_dag_agent_recruitment.py
@@ -50,4 +50,13 @@ depends_on_past=False,
 retries=1, 
 dag=dag)
 
-batch_gen_recruiment >> task_failed 
+a_recruitment_intelligence = SSHOperator(
+ssh_hook=sshHook,
+task_id='a_recruitment_intelligence',
+command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}}  ',
+params={'my_param':"a_recruitment_intelligence_agi"},
+depends_on_past=False, 
+retries=3, 
+dag=dag)
+batch_gen_recruiment >> a_recruitment_intelligence
+a_recruitment_intelligence >> task_failed