File tree Expand file tree Collapse file tree 2 files changed +4
-5
lines changed
Expand file tree Collapse file tree 2 files changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -920,14 +920,14 @@ def _read_parquet(
920920 unified_schema = unify_schemas_pa (schemas )
921921 tables = [cast_schema (t , unified_schema ) for t in tables ]
922922 result = pa .concat_tables (tables , promote_options = "permissive" )
923- #if opt_dtypes:
923+ # if opt_dtypes:
924924 # result = opt_dtype_pa(result, strict=False)
925925 return result
926926 elif isinstance (tables , pa .Table ):
927- #if opt_dtypes:
927+ # if opt_dtypes:
928928 # tables = opt_dtype_pa(tables, strict=False)
929929 return tables
930- #else:
930+ # else:
931931 # return pa.concat_tables(tables, promote_options="permissive")
932932 return tables
933933
@@ -1045,7 +1045,7 @@ def _read_parquet_batches(
10451045 unified_schema = unify_schemas_pa (schemas )
10461046 batch_tables = [cast_schema (t , unified_schema ) for t in batch_tables ]
10471047 result = pa .concat_tables (batch_tables , promote_options = "permissive" )
1048- #if opt_dtypes:
1048+ # if opt_dtypes:
10491049 # result = opt_dtype_pa(result, strict=False)
10501050 yield result
10511051 else :
Original file line number Diff line number Diff line change @@ -221,7 +221,6 @@ def _load(
221221 reload = True
222222 self .use_threads = use_threads
223223
224-
225224 if opt_dtypes is not None :
226225 if self .opt_dtypes != opt_dtypes :
227226 reload = True
You can’t perform that action at this time.
0 commit comments