python/ray/data/datasource/partitioning.py
def _normalize_base_dir(self):
        """Normalizes the partition base directory for compatibility with the
        given filesystem.

        This should be called once a filesystem has been resolved to ensure that this
        base directory is correctly discovered at the root of all partitioned file
        paths.
        """
        from ray.data.datasource.file_based_datasource import (
            _resolve_paths_and_filesystem,
        )

        paths, self._resolved_filesystem = _resolve_paths_and_filesystem(
            self._base_dir,
            self._filesystem,
        )
        assert (
            len(paths) == 1
        ), f"Expected 1 normalized base directory, but found {len(paths)}"
        normalized_base_dir = paths[0]
        if len(normalized_base_dir) and not normalized_base_dir.endswith("/"):
            normalized_base_dir += "/"
        self._normalized_base_dir = normalized_base_dir
Normalizes the partition base directory for compatibility with the
        given filesystem.

        This should be called once a filesystem has been resolved to ensure that this
        base directory is correctly discovered at the root of all partitioned file
        paths.
        
Normalizes the partition base directory for compatibility with the
given filesystem.

This should be called once a filesystem has been resolved to ensure that this
base directory is correctly discovered at the root of all partitioned file
paths.
Normalizes the partition base directory for compatibility with the given filesystem . This should be called once a filesystem has been resolved to ensure that this base directory is correctly discovered at the root of all partitioned file paths .
def _normalize_base_dir(self):
        from ray.data.datasource.file_based_datasource import (
            _resolve_paths_and_filesystem,
        )
        paths, self._resolved_filesystem = _resolve_paths_and_filesystem(
            self._base_dir,
            self._filesystem,
        )
        assert (
            len(paths) == 1
        ), f"Expected 1 normalized base directory, but found {len(paths)}"
        normalized_base_dir = paths[0]
        if len(normalized_base_dir) and not normalized_base_dir.endswith("/"):
            normalized_base_dir += "/"
        self._normalized_base_dir = normalized_base_dir
def _normalize_base_dir ( self ) : from ray . data . datasource . file_based_datasource import ( _resolve_paths_and_filesystem , ) paths , self . _resolved_filesystem = _resolve_paths_and_filesystem ( self . _base_dir , self . _filesystem , ) assert ( len ( paths ) == 1 ) , f"Expected 1 normalized base directory, but found {len(paths)}" normalized_base_dir = paths [ 0 ] if len ( normalized_base_dir ) and not normalized_base_dir . endswith ( "/" ) : normalized_base_dir += "/" self . _normalized_base_dir = normalized_base_dir
Normalizes the partition base directory for compatibility with the
given filesystem.
Normalizes the partition base directory for compatibility with the given filesystem .
"""Normalizes the partition base directory for compatibility with the
        given filesystem.

        This should be called once a filesystem has been resolved to ensure that this
        base directory is correctly discovered at the root of all partitioned file
        paths.
        """
self