diff --git a/src/datachain/data_storage/metastore.py b/src/datachain/data_storage/metastore.py index ef81f56a5..61d7865a7 100644 --- a/src/datachain/data_storage/metastore.py +++ b/src/datachain/data_storage/metastore.py @@ -685,13 +685,6 @@ def _parse_dataset(self, rows) -> Optional[DatasetRecord]: return None return reduce(lambda ds, version: ds.merge_versions(version), versions) - def _parse_datasets(self, rows) -> Iterator["DatasetRecord"]: - # grouping rows by dataset id - for _, g in groupby(rows, lambda r: r[0]): - dataset = self._parse_dataset(list(g)) - if dataset: - yield dataset - def _parse_list_dataset(self, rows) -> Optional[DatasetListRecord]: versions = [self.dataset_list_class.parse(*r) for r in rows] if not versions: