Skip to content

Commit cc25aff

Browse files
authored
Fix dataset info cache assignment (dask#11840)
1 parent bd3a7d6 commit cc25aff

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

dask/dataframe/dask_expr/io/parquet.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1409,7 +1409,7 @@ def _dataset_info(self):
14091409
dataset_info["all_columns"] = all_columns
14101410
dataset_info["calculate_divisions"] = self.calculate_divisions
14111411

1412-
self._dataset_info_cache - dataset_info
1412+
self._dataset_info_cache = dataset_info
14131413
return dataset_info
14141414

14151415
def _filtered_task(self, name: Key, index: int) -> Task:
@@ -1476,7 +1476,6 @@ def _plan(self):
14761476
def _get_lengths(self) -> tuple | None:
14771477
"""Return known partition lengths using parquet statistics"""
14781478
if not self.filters:
1479-
self._update_length_statistics()
14801479
return tuple(
14811480
length
14821481
for i, length in enumerate(self._pq_length_stats)

0 commit comments

Comments
 (0)