diff --git a/pyproject.toml b/pyproject.toml index 0466776..3c2d69a 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -12,7 +12,7 @@ dependencies = [ "apppublic", "sqlor", "ahserver", - "pymilrus" + "pymilvus" ] [tool.setuptools.packages.find] diff --git a/vdb/init.py b/vdb/init.py index 04218aa..b6eb835 100644 --- a/vdb/init.py +++ b/vdb/init.py @@ -35,7 +35,7 @@ async def drop_collection(request, params_kw, *args, **kwargs): env = request._run_ns f = awaitify(env.vdb.drop_collection) try: - r = awiat f(colname) + r = await f(colname) return { "status": "SUCCEEDED" } @@ -55,7 +55,7 @@ async def upsert(request, params_kw, *args, **kwargs): env = request._run_ns f = awaitify(env.vdb.upsert) try: - r = awiat f(colname, data) + r = await f(colname, data) return { "status": "SUCCEEDED" } @@ -73,7 +73,7 @@ async def delete(request, params_kw, *args, **kwargs): env = request._run_ns f = awaitify(env.vdb.delete) try: - r = awiat f(colname, pks) + r = await f(colname, pks) return { "status": "SUCCEEDED" } @@ -97,7 +97,7 @@ async def query(request, params_kw, *args, **kwargs): f1 = awaitify(env.vdb.drop_collection) try: f = partial(f1, colname, vector=vector, expr=expr, pagerows=pagerows, page=page, output_fields=output_fields) - r = awiat f() + r = await f() return { "status": "SUCCEEDED" "data": r