update EmbeddedDatabase

rdsea · Nov 28, 2024 · e410b0a · e410b0a
1 parent 9d5c1ca
commit e410b0a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/pyproject.toml b/pyproject.toml
@@ -10,7 +10,7 @@ include = ["src/qoa4ml"]
 
 [project]
 name = "qoa4ml"
-version = "0.3.16"
+version = "0.3.18"
 description = "Quality of Analysis for Machine Learning"
 readme = "README.md"
 

diff --git a/src/qoa4ml/observability/odop_obs/embedded_database.py b/src/qoa4ml/observability/odop_obs/embedded_database.py
@@ -4,11 +4,12 @@
 from pathlib import Path
 
 from tinyflux import Point, TimeQuery, TinyFlux
+from tinyflux.storages import CSVStorage
 
 
 class EmbeddedDatabase:
     def __init__(self, db_path: Path) -> None:
-        self.db = TinyFlux(db_path)
+        self.db = TinyFlux(db_path, flush_on_insert=False, storage=CSVStorage)
 
     def insert(self, timestamp: float, tags: dict, fields: dict):
         timestamp_datetime = datetime.fromtimestamp(timestamp)