From 099d947c0050cd2cf6fc23117fec08a5172c8aa9 Mon Sep 17 00:00:00 2001 From: Arup Sarker Date: Sat, 8 Jun 2024 18:38:52 -0400 Subject: [PATCH] [Cylon] fix test failure with distributed io and python 3.11 Signed-off-by: Arup Sarker --- python/pycylon/pycylon/distributed_io.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/pycylon/pycylon/distributed_io.py b/python/pycylon/pycylon/distributed_io.py index 8d6660541..346a4e627 100644 --- a/python/pycylon/pycylon/distributed_io.py +++ b/python/pycylon/pycylon/distributed_io.py @@ -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)))