diff --git a/src/flow/src/batching_mode/task.rs b/src/flow/src/batching_mode/task.rs index 44aa1665d4e..610d9c5d2e5 100644 --- a/src/flow/src/batching_mode/task.rs +++ b/src/flow/src/batching_mode/task.rs @@ -1170,6 +1170,7 @@ fn build_pk_from_aggr(plan: &LogicalPlan) -> Result, Error> { } #[cfg(test)] +#[allow(clippy::await_holding_lock)] mod test { use std::collections::BTreeMap; use std::sync::Arc;