merge

alpha-unito · Dec 1, 2023 · 13f2fdb · 13f2fdb
1 parent 0a793f1
commit 13f2fdb
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 10 deletions.
diff --git a/streamflow/core/persistence.py b/streamflow/core/persistence.py
@@ -286,8 +286,8 @@ async def update_command(
         ...
 
     @abstractmethod
-    async def update_config(
-        self, config_id: int, updates: MutableMapping[str, Any]
+    async def update_deployment(
+        self, deployment_id: int, updates: MutableMapping[str, Any]
     ) -> int:
         ...
 

diff --git a/streamflow/persistence/base.py b/streamflow/persistence/base.py
@@ -10,7 +10,7 @@
 class CachedDatabase(Database, ABC):
     def __init__(self, context: StreamFlowContext):
         super().__init__(context)
-        self.config_cache: Cache = LRUCache(maxsize=sys.maxsize)
+        self.deployment_cache: Cache = LRUCache(maxsize=sys.maxsize)
         self.port_cache: Cache = LRUCache(maxsize=sys.maxsize)
         self.step_cache: Cache = LRUCache(maxsize=sys.maxsize)
         self.target_cache: Cache = LRUCache(maxsize=sys.maxsize)

diff --git a/streamflow/persistence/schemas/sqlite.sql b/streamflow/persistence/schemas/sqlite.sql
@@ -78,14 +78,15 @@ CREATE TABLE IF NOT EXISTS provenance
 );
 
 
-CREATE TABLE IF NOT EXISTS config
+CREATE TABLE IF NOT EXISTS deployment
 (
-    id              INTEGER PRIMARY KEY,
-    name            TEXT,
-    attr_type       TEXT,
-    config          TEXT,
-    type            TEXT,
-    params          TEXT
+    id       INTEGER PRIMARY KEY,
+    name     TEXT,
+    type     TEXT,
+    config   TEXT,
+    external INTEGER,
+    lazy     INTEGER,
+    workdir  TEXT
 );