@@ -204,7 +204,9 @@ def _read_parquet_into_table(
204204 engine = "pyarrow" ,
205205 ) as parquet_file :
206206 if _is_fh_a_dir (parquet_file ):
207- _read_remote_parquet_directory (path_to_data , filesystem , storage_options , columns , ** kwargs )
207+ return _read_remote_parquet_directory (
208+ path_to_data , filesystem , storage_options , columns , ** kwargs
209+ )
208210 return pq .read_table (parquet_file , columns = columns , ** kwargs )
209211
210212 # All other cases, including file-like objects, directories, and
@@ -253,8 +255,9 @@ def _read_remote_parquet_directory(
253255 ) as parquet_file :
254256 # Go recursively for supported filesystems, etc. for S3, but not for HTTP(S).
255257 if _is_fh_a_dir (parquet_file ):
256- _read_remote_parquet_directory (upath , columns , ** kwargs )
257- table = pq .read_table (parquet_file , columns = columns , ** kwargs )
258+ table = _read_remote_parquet_directory (upath , filesystem , storage_options , columns , ** kwargs )
259+ else :
260+ table = pq .read_table (parquet_file , columns = columns , ** kwargs )
258261 tables .append (table )
259262 return pa .concat_tables (tables )
260263
0 commit comments