From 15b1d2043e2edc8fcc69922fb75ed0afb964fc61 Mon Sep 17 00:00:00 2001 From: discord9 Date: Fri, 29 May 2026 15:43:10 +0800 Subject: [PATCH] chore: fix query metrics test fallout Signed-off-by: discord9 --- src/query/src/metrics.rs | 21 +++++++++++++++++++++ 1 file changed, 21 insertions(+) diff --git a/src/query/src/metrics.rs b/src/query/src/metrics.rs index 7696291480..feea72e34d 100644 --- a/src/query/src/metrics.rs +++ b/src/query/src/metrics.rs @@ -383,6 +383,7 @@ mod tests { use std::collections::{BTreeMap, BTreeSet}; use std::sync::Arc; + use api::v1::region::{RemoteDynFilterUnregister, RemoteDynFilterUpdate}; use async_trait::async_trait; use datafusion::arrow::datatypes::Schema as ArrowSchema; use datafusion::execution::SessionStateBuilder; @@ -394,6 +395,7 @@ mod tests { use table::table_name::TableName; use super::*; + use crate::dist_plan::ProducerScopeId; use crate::options::{FLOW_RETURN_REGION_SEQ, FLOW_SINK_TABLE_ID}; use crate::region_query::RegionQueryHandler; @@ -408,6 +410,24 @@ mod tests { ) -> Result { unreachable!("metrics tests should not execute remote queries") } + + async fn handle_remote_dyn_filter_update( + &self, + _region_id: RegionId, + _query_id: String, + _update: RemoteDynFilterUpdate, + ) -> Result<()> { + unreachable!("metrics tests should not send remote dyn filter updates") + } + + async fn handle_remote_dyn_filter_unregister( + &self, + _region_id: RegionId, + _query_id: String, + _unregister: RemoteDynFilterUnregister, + ) -> Result<()> { + unreachable!("metrics tests should not send remote dyn filter unregisters") + } } fn metrics_with_region_watermarks(entries: &[(u64, Option)]) -> RecordBatchMetrics { @@ -439,6 +459,7 @@ mod tests { query_ctx, 1, BTreeMap::>::new(), + ProducerScopeId::new(0), ) .unwrap(), )