Bump Version 0.5.15

Author: blythed

pyproject.toml

@@ -6,7 +6,7 @@ build-backend = "setuptools.build_meta"
 name = "superduper-framework"
 description = "🔮 Bring AI to your favourite database 🔮"
 readme = "README.md"
-version = '0.5.14'
+version = '0.5.15'
 license = {file = "LICENSE"}
 maintainers = [{name = "superduper.io, Inc.", email = "opensource@superduper.com"}]
 keywords = [

superduper/rest/build.py

@@ -31,7 +31,10 @@
 
 
 PENDING_COMPONENTS = set()
-lock = threading.Lock()
+# lock = threading.Lock()
+import asyncio
+lock = asyncio.Lock()
+
 
 
 class Tee:
@@ -193,7 +196,7 @@ def describe_tables(db: 'Datalayer' = DatalayerDependency()):
         return db.databackend.list_tables_or_collections()
 
     @app.add('/db/apply', method='post')
-    def db_apply(
+    async def db_apply(
         info: t.Dict,
         background_tasks: BackgroundTasks,
         id: str | None = 'test',
@@ -202,7 +205,7 @@ def db_apply(
         cls_path = info['_builds'][info['_base'][1:]]['_path']
         cls = import_object(cls_path)
         type_id = cls.type_id
-        with lock:
+        async with lock:
             PENDING_COMPONENTS.add((type_id, info['identifier']))
         if '_variables' in info:
             info['_variables']['output_prefix'] = CFG.output_prefix
@@ -273,10 +276,10 @@ def db_show(
             return out
 
     @app.add('/db/remove', method='post')
-    def db_remove(
+    async def db_remove(
         type_id: str, identifier: str, db: 'Datalayer' = DatalayerDependency()
     ):
-        with lock:
+        async with lock:
             PENDING_COMPONENTS.discard((type_id, identifier))
         db.remove(type_id=type_id, identifier=identifier, recursive=True, force=True)
         return {'status': 'ok'}