diff --git a/Cargo.lock b/Cargo.lock index 290a1e4bf28f..893b1b9a345e 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -3701,7 +3701,6 @@ dependencies = [ "user-facing-errors", "uuid", "wasm-bindgen-futures", - "wasm-rs-dbg", ] [[package]] diff --git a/query-engine/core/Cargo.toml b/query-engine/core/Cargo.toml index a43006b89160..370ce6b81ec5 100644 --- a/query-engine/core/Cargo.toml +++ b/query-engine/core/Cargo.toml @@ -37,7 +37,6 @@ schema = { path = "../schema" } elapsed = { path = "../../libs/elapsed" } lru = "0.7.7" enumflags2 = "0.7" -wasm-rs-dbg.workspace = true pin-project = "1" wasm-bindgen-futures = "0.4" diff --git a/query-engine/core/src/executor/task.rs b/query-engine/core/src/executor/task.rs index 1fe69c240d2c..f127da55fc00 100644 --- a/query-engine/core/src/executor/task.rs +++ b/query-engine/core/src/executor/task.rs @@ -62,7 +62,6 @@ mod arch { broadcast::{self}, oneshot::{self}, }; - use wasm_rs_dbg::dbg; // Wasm-compatible alternative to `tokio::task::JoinHandle`. // `pin_project` enables pin-projection and a `Pin`-compatible implementation of the `Future` trait. @@ -78,8 +77,6 @@ mod arch { type Output = Result; fn poll(mut self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>) -> std::task::Poll { - dbg!("JoinHandle::poll"); - // the `self.project()` method is provided by the `pin_project` macro core::pin::Pin::new(&mut self.receiver).poll(cx) } @@ -87,10 +84,7 @@ mod arch { impl JoinHandle { pub fn abort(&mut self) { - dbg!("JoinHandle::abort"); - if let Some(sx_exit) = self.sx_exit.as_ref() { - dbg!("JoinHandle::abort - Send sx_exit"); sx_exit.send(()).ok(); } } diff --git a/query-engine/core/src/interactive_transactions/actors.rs b/query-engine/core/src/interactive_transactions/actors.rs index 58d24c528261..5af01260a921 100644 --- a/query-engine/core/src/interactive_transactions/actors.rs +++ b/query-engine/core/src/interactive_transactions/actors.rs @@ -392,7 +392,6 @@ pub(crate) fn spawn_client_list_clear_actor( loop { tokio::select! { result = rx.recv() => { - dbg!("spawn_controlled - AFTER rx.recv(): {:?}", result.is_some()); match result { Some((id, closed_tx)) => { trace!("removing {} from client list", id); @@ -411,7 +410,6 @@ pub(crate) fn spawn_client_list_clear_actor( } }, _ = rx_exit.recv() => { - dbg!("spawn_controlled - AFTER rx_exit.recv()"); break; }, }