From 6dec3482fc681f53ca2909416f12059eba213a33 Mon Sep 17 00:00:00 2001 From: Mats Eikeland Mollestad Date: Mon, 15 Dec 2025 09:33:42 +0100 Subject: [PATCH 1/2] Updated write to cluster --- aligned/sources/redis.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/aligned/sources/redis.py b/aligned/sources/redis.py index 79709b5f..a60172c0 100644 --- a/aligned/sources/redis.py +++ b/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: From caf61c7d532ef2d35822ce121cd3c7c57660b826 Mon Sep 17 00:00:00 2001 From: Mats Eikeland Mollestad Date: Mon, 15 Dec 2025 08:38:16 +0000 Subject: [PATCH 2/2] Updated version nr --- aligned/__init__.py | 2 +- pyproject.toml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/aligned/__init__.py b/aligned/__init__.py index 2d8f1491..098eb29a 100644 --- a/aligned/__init__.py +++ b/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", diff --git a/pyproject.toml b/pyproject.toml index 82a622c1..46c67234 100644 --- a/pyproject.toml +++ b/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 "] license = "FSL-1.1-ALv2"