Skip to content

Commit

Permalink
[Cylon] fix test failure with distributed io and python 3.11
Browse files Browse the repository at this point in the history
Signed-off-by: Arup Sarker <[email protected]>
  • Loading branch information
arupcsedu committed Jun 8, 2024
1 parent 5778f14 commit 099d947
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion python/pycylon/pycylon/distributed_io.py
Original file line number Diff line number Diff line change
Expand Up @@ -238,7 +238,7 @@ def read_parquet_dist(paths: Union[str, List[str], Dict[int, Union[str, List[str
for file in worker_files:
dfs.append(DataFrame(pq.read_table(file,
# keyword arguments to pass into pq.read_table
metadata=metadata, read_dictionary=read_dictionary,
read_dictionary=read_dictionary,
memory_map=memory_map, buffer_size=buffer_size, pre_buffer=pre_buffer,
coerce_int96_timestamp_unit=coerce_int96_timestamp_unit,
columns=columns, use_threads=use_threads, use_pandas_metadata=use_pandas_metadata, **kwargs)))
Expand Down

0 comments on commit 099d947

Please sign in to comment.