fix: use return in dspy (wrapped as async def)

This commit is contained in:
yumoqing 2026-07-23 11:36:38 +08:00
parent 51f0fd680b
commit f44566a7c4
3 changed files with 6 additions and 7 deletions

View File

@ -3,5 +3,5 @@ db = DBPools()
dbname = get_module_dbname('rag')
async with db.sqlorContext(dbname) as sor:
await sor.sqlExe("DELETE FROM document_chunks WHERE id=${id}$", {"id": ns.get("id","")})
result = {"widgettype": "Message", "options": {"user_data": {"id": ns.get("id","")}}}
result
return {"widgettype": "Message", "options": {"user_data": {"id": ns.get("id","")}}}
return {"error": "failed"}

View File

@ -11,5 +11,5 @@ async with db.sqlorContext(dbname) as sor:
"INSERT INTO document_chunks (id, doc_id, kb_id, chunk_index, chunk_type, content, description, created_at) "
"VALUES (${id}$, '', ${kb_id}$, 0, 'directory', ${name}$, ${parentid}$, NOW())",
{"id": dir_id, "kb_id": kb_id, "name": name, "parentid": parent_id})
result = {"widgettype": "Message", "options": {"user_data": {"id": dir_id, "label": name, "parentid": parent_id}}}
result
return {"widgettype": "Message", "options": {"user_data": {"id": dir_id, "label": name, "parentid": parent_id}}}
return {"error": "failed"}

View File

@ -3,9 +3,8 @@ db = DBPools()
dbname = get_module_dbname('rag')
async with db.sqlorContext(dbname) as sor:
id = ns.get("id", "")
kb_id = ns.get("kb_id", "")
name = ns.get("name", "")
await sor.sqlExe("UPDATE document_chunks SET content=${name}$ WHERE id=${id}$",
{"name": name, "id": id})
result = {"widgettype": "Message", "options": {"user_data": {"id": id, "label": name}}}
result
return {"widgettype": "Message", "options": {"user_data": {"id": id, "label": name}}}
return {"error": "failed"}