From d22b97c184364bab62fc0b0f1419065ab1d0af61 Mon Sep 17 00:00:00 2001 From: Orson Peters Date: Tue, 28 Jan 2025 19:34:59 +0100 Subject: [PATCH] fmt --- crates/polars-error/src/signals.rs | 8 +++----- crates/polars-stream/src/async_executor/task.rs | 1 - 2 files changed, 3 insertions(+), 6 deletions(-) diff --git a/crates/polars-error/src/signals.rs b/crates/polars-error/src/signals.rs index 57a6ba4aa3d0..c7c360532121 100644 --- a/crates/polars-error/src/signals.rs +++ b/crates/polars-error/src/signals.rs @@ -63,11 +63,9 @@ pub fn catch_keyboard_interrupt R + UnwindSafe>( try_register_catcher()?; let ret = catch_unwind(try_fn); unregister_catcher(); - ret.map_err(|p| { - match p.downcast::() { - Ok(_) => KeyboardInterrupt, - Err(p) => std::panic::resume_unwind(p), - } + ret.map_err(|p| match p.downcast::() { + Ok(_) => KeyboardInterrupt, + Err(p) => std::panic::resume_unwind(p), }) } diff --git a/crates/polars-stream/src/async_executor/task.rs b/crates/polars-stream/src/async_executor/task.rs index 69c9a351e8e1..60b12f14bccb 100644 --- a/crates/polars-stream/src/async_executor/task.rs +++ b/crates/polars-stream/src/async_executor/task.rs @@ -8,7 +8,6 @@ use std::task::{Context, Poll, Wake, Waker}; use atomic_waker::AtomicWaker; use parking_lot::Mutex; - use polars_error::signals::try_raise_keyboard_interrupt; /// The state of the task. Can't be part of the TaskData enum as it needs to be