Skip to content

Commit

Permalink
Merge branch 'main' into dependabot/pip/development-dependencies-e9fe…
Browse files Browse the repository at this point in the history
…132cac
  • Loading branch information
malachi-constant authored Oct 28, 2024
2 parents 0e5e3c3 + f6825c2 commit 57b83d2
Showing 1 changed file with 2 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -30,11 +30,9 @@
from ray.data.block import Block
from ray.data.context import DataContext
from ray.data.datasource import Datasource
from ray.data.datasource._default_metadata_providers import (
get_generic_metadata_provider,
)
from ray.data.datasource.datasource import ReadTask
from ray.data.datasource.file_meta_provider import (
DefaultFileMetadataProvider,
_handle_read_os_error,
)
from ray.data.datasource.parquet_meta_provider import (
Expand Down Expand Up @@ -219,7 +217,7 @@ def __init__( # noqa: PLR0912,PLR0915
# files. To avoid this, we expand the input paths with the default metadata
# provider and then apply the partition filter or file extensions.
if partition_filter is not None or file_extensions is not None:
default_meta_provider = get_generic_metadata_provider(file_extensions=None)
default_meta_provider = DefaultFileMetadataProvider()
expanded_paths, _ = map(list, zip(*default_meta_provider.expand_paths(paths, filesystem)))

paths = list(expanded_paths)
Expand Down

0 comments on commit 57b83d2

Please sign in to comment.