From 37a72f340669cdd985e992d8e37916c6575414d6 Mon Sep 17 00:00:00 2001 From: Jonas Knobloch Date: Tue, 21 Apr 2026 19:45:26 +0200 Subject: Propagate record reader error --- dataset/parquet.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/dataset/parquet.go b/dataset/parquet.go index 6710260..4b3d858 100644 --- a/dataset/parquet.go +++ b/dataset/parquet.go @@ -161,6 +161,12 @@ func (p *ParquetReader) read(name string) iter.Seq[string] { } } } + + if err := recordReader.Err(); err != nil { + p.err = err + + return + } } } -- cgit v1.2.3