We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 37f0d12 commit e66f769Copy full SHA for e66f769
src/query/service/src/pipelines/processors/transforms/transform_async_function.rs
@@ -601,7 +601,7 @@ mod tests {
601
602
let (tx, mut rx) = tokio::sync::oneshot::channel();
603
let counter_for_read = counter.clone();
604
- tokio::task::spawn_blocking(move || {
+ databend_common_base::runtime::spawn_blocking(move || {
605
let _ = tx.send(counter_for_read.load_bounds());
606
});
607
0 commit comments