We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2c79412 commit c759f70Copy full SHA for c759f70
src/query/service/src/pipelines/processors/transforms/transform_async_function.rs
@@ -1147,7 +1147,7 @@ mod tests {
1147
1148
let (tx, mut rx) = tokio::sync::oneshot::channel();
1149
let counter_for_read = counter.clone();
1150
- tokio::task::spawn_blocking(move || {
+ databend_common_base::runtime::spawn_blocking(move || {
1151
let _ = tx.send(counter_for_read.load_bounds());
1152
});
1153
0 commit comments