Updated write to cluster (#47)

* Updated write to cluster

* Updated version nr

Author: MatsMoll

aligned/__init__.py

@@ -45,7 +45,7 @@
 from aligned.exposed_model.interface import ExposedModel
 from aligned.schemas.feature import FeatureLocation
 
-__version__ = "0.0.134"
+__version__ = "0.0.135"
 
 __all__ = [
     "ContractStore",

aligned/sources/redis.py

@@ -236,7 +236,7 @@ async def insert(self, job: RetrievalJob, request: RetrievalRequest) -> None:
         redis = self.config.redis()
         data = await job.to_lazy_polars()
 
-        async with redis.pipeline(transaction=True) as pipe:
+        async with redis.pipeline(transaction=False) as pipe:
             # Run one query per row
             filter_entity_query: pl.Expr = pl.lit(True)
             for entity_name in request.entity_names:

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "aligned"
-version = "0.0.134"
+version = "0.0.135"
 description = "A data management and lineage tool for ML applications."
 authors = ["Mats E. Mollestad <mats@mollestad.no>"]
 license = "FSL-1.1-ALv2"