yumoqing/pipeline-sdlc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

tmp: kb_diag4修正SQL参数

Browse Source
This commit is contained in:
ymq 2026-09-04 19:52:54 +08:00
parent 97d1f7aec4
commit a1ddf7a9ca
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
wwwroot/api/kb_diag4.dspy
View File

@ -25,14 +25,14 @@ try:
async with DBPools().sqlorContext(dbname) as sor: async with DBPools().sqlorContext(dbname) as sor:
recs = await sor.sqlExe( recs = await sor.sqlExe(
"SELECT id, kb_id, file_name, status FROM pipeline_kb_suggestions " "SELECT id, kb_id, file_name, status FROM pipeline_kb_suggestions "
"ORDER BY created_at DESC LIMIT 1") "ORDER BY created_at DESC LIMIT 1", {})
await sor.sqlExe("COMMIT", {}) await sor.sqlExe("COMMIT", {})
if recs: if recs:
out["suggestion"] = {"id": recs[0].id, "kb_id": recs[0].kb_id, out["suggestion"] = {"id": recs[0].id, "kb_id": recs[0].kb_id,
"file_name": recs[0].file_name, "status": recs[0].status} "file_name": recs[0].file_name, "status": recs[0].status}
ht = await sor.sqlExe( ht = await sor.sqlExe(
"SELECT id, task_type, assignee_id, status, form_schema FROM pipeline_human_tasks " "SELECT id, task_type, assignee_id, status, form_schema FROM pipeline_human_tasks "
"WHERE task_type='kb_ingest_confirm' ORDER BY created_at DESC LIMIT 1") "WHERE task_type='kb_ingest_confirm' ORDER BY created_at DESC LIMIT 1", {})
await sor.sqlExe("COMMIT", {}) await sor.sqlExe("COMMIT", {})
if ht: if ht:
out["human_task"] = {"id": ht[0].id, "task_type": ht[0].task_type, out["human_task"] = {"id": ht[0].id, "task_type": ht[0].task_type,