Fix V3IO driver following change in v3io-py (#532)

[ML-7715](https://iguazio.atlassian.net/browse/ML-7715) [This change](https://github.com/v3io/v3io-py/pull/126/files#diff-c6f2958ca59ceba44b4c4426fdf625aa344032067191d75ecacc5d956820cf3fR42) to a utility method in v3io-py changed its return type from bytes to string.
mlrun · Sep 2, 2024 · f89c2ef · f89c2ef
1 parent 48d5ea7
commit f89c2ef
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/requirements.txt b/requirements.txt
@@ -1,5 +1,5 @@
 aiohttp~=3.8
-v3io~=0.6.4
+v3io~=0.6.9
 # exclude pandas 1.5.0 due to https://github.com/pandas-dev/pandas/issues/48767
 # and 1.5.* due to https://github.com/pandas-dev/pandas/issues/49203
 # pandas 2.2 requires sqlalchemy 2

diff --git a/storey/drivers.py b/storey/drivers.py
@@ -532,7 +532,7 @@ def _build_simplified_feature_store_request(self, aggregation_element):
 
         if use_parallel:
             for attr_name, d in pexpressions.items():
-                encoded_array = kv_array.encode_list(d["values"][d["first_index"] : d["last_index"] + 1]).decode()
+                encoded_array = kv_array.encode_list(d["values"][d["first_index"] : d["last_index"] + 1])
                 paggregate = self.parallel_aggregates[d["aggregation"]]
                 sliced_array = f'{attr_name}[{d["first_index"]}..{d["last_index"]}]'
                 expressions.append(f"{sliced_array}={paggregate}({sliced_array}, blob('{encoded_array}'))")