We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 917741a commit f7e5bd1Copy full SHA for f7e5bd1
ballista/executor/src/cpu_bound_executor.rs
@@ -20,7 +20,7 @@
20
//! This module contains a dedicated thread pool for running "cpu
21
//! intensive" workloads as query plans
22
23
-use log::warn;
+use log::{debug, warn};
24
use parking_lot::Mutex;
25
use std::{pin::Pin, sync::Arc};
26
use tokio::sync::oneshot::Receiver;
@@ -146,7 +146,7 @@ impl DedicatedExecutor {
146
let job = Box::pin(async move {
147
let task_output = task.await;
148
if tx.send(task_output).is_err() {
149
- warn!("Spawned task output ignored: receiver dropped");
+ debug!("Spawned task output ignored: receiver dropped");
150
}
151
});
152
0 commit comments