Skip to content

Commit ea3673b

Browse files
committed
handle error from wait_for_future in PySubstraitSerializer
1 parent ccb4a5c commit ea3673b

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/substrait.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,8 @@ impl PySubstraitSerializer {
8383

8484
// Suppress the specific warning while maintaining the behavior that works with Tokio
8585
#[allow(unused_must_use)]
86-
wait_for_future(py, future)?;
86+
wait_for_future(py, future)?.map_err(PyDataFusionError::from)?;
87+
8788
Ok(())
8889
}
8990

0 commit comments

Comments
 (0)