From 2a8eb59a148ab0b5c81e4e28c818cce5a70a7fcb Mon Sep 17 00:00:00 2001 From: discord9 Date: Mon, 1 Jun 2026 21:13:27 +0800 Subject: [PATCH] chore: import Signed-off-by: discord9 --- src/query/src/dist_plan/dyn_filter_bridge.rs | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/src/query/src/dist_plan/dyn_filter_bridge.rs b/src/query/src/dist_plan/dyn_filter_bridge.rs index 3a27fea5c5..41a95b22f1 100644 --- a/src/query/src/dist_plan/dyn_filter_bridge.rs +++ b/src/query/src/dist_plan/dyn_filter_bridge.rs @@ -23,14 +23,8 @@ use datafusion::execution::TaskContext; use datafusion_common::Result; use datafusion_physical_expr::PhysicalExpr; use datafusion_physical_expr::expressions::DynamicFilterPhysicalExpr; -#[cfg(test)] -use datafusion_physical_expr::expressions::{Column, lit}; use session::context::{QueryContext, QueryContextRef}; -#[cfg(test)] -use session::query_id::QueryId; use store_api::storage::RegionId; -#[cfg(test)] -use uuid::Uuid; use crate::dist_plan::filter_id::build_remote_dyn_filter_id; use crate::dist_plan::{FilterId, ProducerScopeId, QueryDynFilterRegistry, Subscriber}; @@ -195,6 +189,10 @@ pub(crate) fn query_context_with_initial_dyn_filter_regs( #[cfg(test)] mod tests { + use datafusion_physical_expr::expressions::{Column, lit}; + use session::query_id::QueryId; + use uuid::Uuid; + use super::*; fn test_query_id(value: u128) -> QueryId {