rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-11-14 06:46:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(promql): pass explicit input slots to fused collision fixture

Browse Source 
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
This commit is contained in:
discord9
2026-10-24 18:52:06 +08:00
parent d8058bbd65
commit 1bc32e3ee2
1 changed files with 23 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/promql/src/extension_plan/fused_series/tests.rs
+23 -17
View File
@@ -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)),
&times_of(&samples),
vec![values_of(&samples)],
true,
))
.push_raw(
InputId::new(0),
chunk_of(
&raw_schema(),
METRIC,
metric(&[(HOST, "web-1")], Some(METRIC)),
&times_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")),
&times_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")),
&times_of(&samples),
vec![values_of(&samples)],
true,
),
)
.expect("the second series is a legal raw chunk");
let error = execution
.next_chunk()