Skip to content

Commit f89c2ef

Browse files
authored
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.
1 parent 48d5ea7 commit f89c2ef

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

requirements.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
aiohttp~=3.8
2-
v3io~=0.6.4
2+
v3io~=0.6.9
33
# exclude pandas 1.5.0 due to https://github.com/pandas-dev/pandas/issues/48767
44
# and 1.5.* due to https://github.com/pandas-dev/pandas/issues/49203
55
# pandas 2.2 requires sqlalchemy 2

storey/drivers.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -532,7 +532,7 @@ def _build_simplified_feature_store_request(self, aggregation_element):
532532

533533
if use_parallel:
534534
for attr_name, d in pexpressions.items():
535-
encoded_array = kv_array.encode_list(d["values"][d["first_index"] : d["last_index"] + 1]).decode()
535+
encoded_array = kv_array.encode_list(d["values"][d["first_index"] : d["last_index"] + 1])
536536
paggregate = self.parallel_aggregates[d["aggregation"]]
537537
sliced_array = f'{attr_name}[{d["first_index"]}..{d["last_index"]}]'
538538
expressions.append(f"{sliced_array}={paggregate}({sliced_array}, blob('{encoded_array}'))")

0 commit comments

Comments
 (0)