add workflow 招聘信息导入,dev

dev/workflow/TK_Cust/agent_recruitment/批量处理招聘数据/batch_gen_recruiment.py

@@ -260,7 +260,7 @@ def main():
     
     # API配置
     api_config = {
-        'url': 'https://tk-agent.idgvalue.com/v1/workflows/run',
+        'url': 'http://tk-agent.idgvalue.com/v1/workflows/run',
         'auth_token': 'Bearer app-siNKLRExkzO9IM81P8hHuBx2'
     }
 
@@ -284,7 +284,7 @@ WHERE ds.dataset_id = '33d1b946-acd2-4538-b6cc-e0cd77824aba'
   AND ds.enabled
   AND ds.created_at >= NOW() - INTERVAL '48 hours'
 GROUP BY ds.document_id
-ORDER BY doc_time DESC """
+ORDER BY doc_time DESC limit 10 """
             
             try:
                 # 从数据库获取URL列表
@@ -298,7 +298,7 @@ ORDER BY doc_time DESC """
                 for i, text in enumerate(list, 1):
                     logger.info(f"处理第 {i}/{len(list)} 个数据: {text}")
                     
-                    if type == 'workflow':
+                    if type is 'workflow':
                       # 方法1: 使用带inputs参数的调用
                       inputs_data = {
                           "content": f"{text}",
@@ -335,7 +335,7 @@ ORDER BY doc_time DESC """
 
         else:
             logger.info("调用不带inputs参数的API示例")
-            if type == 'workflow':
+            if type is 'workflow':
               result2 = api_client.call_api_without_inputs()
             
               if result2['success']: