From ca2bb677faf1222e2d8be3cace04b1eb9837ba83 Mon Sep 17 00:00:00 2001 From: Matthew Rocklin Date: Thu, 29 Feb 2024 09:54:58 -0600 Subject: [PATCH] Sort filenames Fixes #70 --- dask_deltatable/core.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dask_deltatable/core.py b/dask_deltatable/core.py index 7e62333..b89e6d8 100644 --- a/dask_deltatable/core.py +++ b/dask_deltatable/core.py @@ -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))