Skip to content

Commit

Permalink
Sort filenames (#71)
Browse files Browse the repository at this point in the history
  • Loading branch information
mrocklin authored Mar 8, 2024
1 parent cbe085a commit 05f7cf1
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion dask_deltatable/core.py
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ def _get_pq_files(dt: DeltaTable, filter: Filters = None) -> list[str]:
partition_filters = get_partition_filters(dt.metadata().partition_columns, filter)
if not partition_filters:
# can't filter
return dt.file_uris()
return sorted(dt.file_uris())
file_uris = set()
for filter_set in partition_filters:
file_uris.update(dt.file_uris(partition_filters=filter_set))
Expand Down

0 comments on commit 05f7cf1

Please sign in to comment.