From 1bc32e3ee22069c384a9502be583be8d40552469 Mon Sep 17 00:00:00 2001 From: discord9 <55937128+discord9@users.noreply.github.com> Date: Fri, 23 Oct 2026 17:55:33 +0800 Subject: [PATCH] test(promql): pass explicit input slots to fused collision fixture Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com> --- .../src/extension_plan/fused_series/tests.rs | 40 +++++++++++-------- 1 file changed, 23 insertions(+), 17 deletions(-) diff --git a/src/promql/src/extension_plan/fused_series/tests.rs b/src/promql/src/extension_plan/fused_series/tests.rs index 7205fbf294e..83edaaaed98 100644 --- a/src/promql/src/extension_plan/fused_series/tests.rs +++ b/src/promql/src/extension_plan/fused_series/tests.rs @@ -73,7 +73,7 @@ use super::{ occupied_runs, series_to_record_batch, }; use crate::evaluated::EvaluatedChunk; -use crate::native::execute::{NativeExecutionState, NativeExecutor}; +use crate::native::execute::{InputId, NativeExecutionState, NativeExecutor}; use crate::native::plan::{ AggregateKind, AggregateStage, BoundAggregate, BoundInput, BoundInstant, BoundWindow, Grouping, NativeExpr, NativeNode, NativeTree, NativeType, @@ -1000,14 +1000,17 @@ fn two_differently_named_series_collide_once_rate_drops_the_name() { ); let samples = series_samples(1.0); execution - .push_raw(chunk_of( - &raw_schema(), - METRIC, - metric(&[(HOST, "web-1")], Some(METRIC)), - ×_of(&samples), - vec![values_of(&samples)], - true, - )) + .push_raw( + InputId::new(0), + chunk_of( + &raw_schema(), + METRIC, + metric(&[(HOST, "web-1")], Some(METRIC)), + ×_of(&samples), + vec![values_of(&samples)], + true, + ), + ) .expect("the first series is a legal raw chunk"); assert!( execution @@ -1017,14 +1020,17 @@ fn two_differently_named_series_collide_once_rate_drops_the_name() { "the first series is answered" ); execution - .push_raw(chunk_of( - &raw_schema(), - "http_errors_total", - metric(&[(HOST, "web-1")], Some("http_errors_total")), - ×_of(&samples), - vec![values_of(&samples)], - true, - )) + .push_raw( + InputId::new(0), + chunk_of( + &raw_schema(), + "http_errors_total", + metric(&[(HOST, "web-1")], Some("http_errors_total")), + ×_of(&samples), + vec![values_of(&samples)], + true, + ), + ) .expect("the second series is a legal raw chunk"); let error = execution .next_chunk()