Jeremie Hallal · Yannick
--- a/app/bulk_persistence/dask/dask_bulk_storage.py
+++ b/app/bulk_persistence/dask/dask_bulk_storage.py

        # read all chunk for requested columns
        def read_parquet_files(f):
-            """ read all chunk for requested columns """
-            return read_with_dask(f.paths, columns=f.labels, storage_options=self._parameters.storage_options)
+            dfs = [pd.read_parquet(pq_file, engine='pyarrow', columns=f.labels, 
+                                   storage_options=self._parameters.storage_options)
+                   for pq_file in f.paths]
+            return pd.concat(dfs)