From 2276553db1d4c3a764758b78a8880d32e9d5dc15 Mon Sep 17 00:00:00 2001 From: Simon Lin Date: Thu, 11 Jul 2024 17:44:25 +1000 Subject: [PATCH] c --- crates/polars-io/src/parquet/read/read_impl.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/crates/polars-io/src/parquet/read/read_impl.rs b/crates/polars-io/src/parquet/read/read_impl.rs index f272daaedc63..b6da32daaaec 100644 --- a/crates/polars-io/src/parquet/read/read_impl.rs +++ b/crates/polars-io/src/parquet/read/read_impl.rs @@ -722,7 +722,9 @@ impl BatchedParquetReader { use_statistics, hive_partition_columns.as_deref(), ); - tx.send((dfs, rows_read, limit)).unwrap(); + + // Don't unwrap send attempt - async task could be cancelled. + let _ = tx.send((dfs, rows_read, limit)); }; // Spawn the task and wait on it asynchronously.