From 4c094044291a30179c799bfaf624722ab80a1f25 Mon Sep 17 00:00:00 2001
From: root <root@64792e78fd4d>
Date: Fri, 27 Feb 2026 09:54:01 +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

---
 .../批量处理招聘数据/batch_gen_recruiment.py                  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/dev/workflow/TK_Cust/agent_recruitment/批量处理招聘数据/batch_gen_recruiment.py b/dev/workflow/TK_Cust/agent_recruitment/批量处理招聘数据/batch_gen_recruiment.py
index 00e0ecc..c001bc1 100644
--- a/dev/workflow/TK_Cust/agent_recruitment/批量处理招聘数据/batch_gen_recruiment.py
+++ b/dev/workflow/TK_Cust/agent_recruitment/批量处理招聘数据/batch_gen_recruiment.py
@@ -276,8 +276,6 @@ def main():
             # 初始化
             db_manager = DatabaseManager(db_config)
             custom_query = """ SELECT
-    ds.document_id,
-    MIN(ds.created_at) AS doc_time,
     string_agg(ds.content, '' ORDER BY ds.position) AS full_text
 FROM public.document_segments ds
 WHERE ds.dataset_id = '33d1b946-acd2-4538-b6cc-e0cd77824aba'
@@ -295,7 +293,7 @@ ORDER BY doc_time DESC limit 10 """
                     return
                 
                 # 遍历每个URL调用API
-                for i, text in enumerate(list, 3):
+                for i, text in enumerate(list, 1):
                     logger.info(f"处理第 {i}/{len(list)} 个数据: {text}")
                     
                     if type == 'workflow':