dtgitea
/
dataops
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add workflow 招聘信息导入,dev

This commit is contained in:
root 2026-02-27 09:46:40 +08:00
parent 5b458c3ab8
commit 257e2b3516
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -282,9 +282,9 @@ def main():
FROM public.document_segments ds FROM public.document_segments ds
WHERE ds.dataset_id = '33d1b946-acd2-4538-b6cc-e0cd77824aba' WHERE ds.dataset_id = '33d1b946-acd2-4538-b6cc-e0cd77824aba'
AND ds.enabled AND ds.enabled
AND ds.created_at >= NOW() - INTERVAL '24 hours' AND ds.created_at >= NOW() - INTERVAL '48 hours'
GROUP BY ds.document_id GROUP BY ds.document_id
ORDER BY doc_time DESC """ ORDER BY doc_time DESC limit 10 """
try: try:
# 从数据库获取URL列表 # 从数据库获取URL列表
@ -298,7 +298,7 @@ ORDER BY doc_time DESC """
for i, text in enumerate(list, 1): for i, text in enumerate(list, 1):
logger.info(f"处理第 {i}/{len(list)} 个数据: {text}") logger.info(f"处理第 {i}/{len(list)} 个数据: {text}")
if type is 'workflow': if type == 'workflow':
# 方法1: 使用带inputs参数的调用 # 方法1: 使用带inputs参数的调用
inputs_data = { inputs_data = {
"content": f"{text}", "content": f"{text}",
@ -335,7 +335,7 @@ ORDER BY doc_time DESC """
else: else:
logger.info("调用不带inputs参数的API示例") logger.info("调用不带inputs参数的API示例")
if type is 'workflow': if type == 'workflow':
result2 = api_client.call_api_without_inputs() result2 = api_client.call_api_without_inputs()
if result2['success']: if result2['success']: