yumoqing/vdb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2026-02-06 13:29:56 +08:00
parent 8330f3e79a
commit 28a311efff
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pyproject.toml
View File

@ -12,7 +12,7 @@ dependencies = [
"apppublic", "apppublic",
"sqlor", "sqlor",
"ahserver", "ahserver",
"pymilrus" "pymilvus"
] ]
[tool.setuptools.packages.find] [tool.setuptools.packages.find]

8
vdb/init.py
View File

@ -35,7 +35,7 @@ async def drop_collection(request, params_kw, *args, **kwargs):
env = request._run_ns env = request._run_ns
f = awaitify(env.vdb.drop_collection) f = awaitify(env.vdb.drop_collection)
try: try:
r = awiat f(colname) r = await f(colname)
return { return {
"status": "SUCCEEDED" "status": "SUCCEEDED"
} }
@ -55,7 +55,7 @@ async def upsert(request, params_kw, *args, **kwargs):
env = request._run_ns env = request._run_ns
f = awaitify(env.vdb.upsert) f = awaitify(env.vdb.upsert)
try: try:
r = awiat f(colname, data) r = await f(colname, data)
return { return {
"status": "SUCCEEDED" "status": "SUCCEEDED"
} }
@ -73,7 +73,7 @@ async def delete(request, params_kw, *args, **kwargs):
env = request._run_ns env = request._run_ns
f = awaitify(env.vdb.delete) f = awaitify(env.vdb.delete)
try: try:
r = awiat f(colname, pks) r = await f(colname, pks)
return { return {
"status": "SUCCEEDED" "status": "SUCCEEDED"
} }
@ -97,7 +97,7 @@ async def query(request, params_kw, *args, **kwargs):
f1 = awaitify(env.vdb.drop_collection) f1 = awaitify(env.vdb.drop_collection)
try: try:
f = partial(f1, colname, vector=vector, expr=expr, pagerows=pagerows, page=page, output_fields=output_fields) f = partial(f1, colname, vector=vector, expr=expr, pagerows=pagerows, page=page, output_fields=output_fields)
r = awiat f() r = await f()
return { return {
"status": "SUCCEEDED" "status": "SUCCEEDED"
"data": r "data": r