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 eec0ff7..bbf686f 100644 --- a/dev/workflow/TK_Cust/agent_recruitment/批量处理招聘数据/batch_gen_recruiment.py +++ b/dev/workflow/TK_Cust/agent_recruitment/批量处理招聘数据/batch_gen_recruiment.py @@ -282,9 +282,9 @@ def main(): FROM public.document_segments ds WHERE ds.dataset_id = '33d1b946-acd2-4538-b6cc-e0cd77824aba' AND ds.enabled - AND ds.created_at >= NOW() - INTERVAL '24 hours' + 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 is 'workflow': + if type == 'workflow': # 方法1: 使用带inputs参数的调用 inputs_data = { "content": f"{text}", @@ -335,7 +335,7 @@ ORDER BY doc_time DESC """ else: logger.info("调用不带inputs参数的API示例") - if type is 'workflow': + if type == 'workflow': result2 = api_client.call_api_without_inputs() if result2['success']: