Skip to content

Commit 78a141e

Browse files
author
Devdutt Shenoi
committed
fix: don't count part.arrows
1 parent a4d5e3d commit 78a141e

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/parseable/streams.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -225,8 +225,10 @@ impl Stream {
225225
.flatten()
226226
.map(|file| file.path())
227227
.filter(|path| {
228-
path.file_name()
229-
.is_some_and(|f| f.to_string_lossy().ends_with(ARROW_FILE_EXTENSION))
228+
path.file_name().is_some_and(|f| {
229+
let filename = f.to_string_lossy();
230+
filename.ends_with(ARROW_FILE_EXTENSION) && !filename.contains("part")
231+
})
230232
})
231233
.sorted_by_key(|f| f.metadata().unwrap().modified().unwrap())
232234
.collect();

0 commit comments

Comments
 (0)