Skip to content

Commit cfafcf1

Browse files
zzylolclaude
andcommitted
refactor(stage2): port kept tumbling panes to Operator<NodeId> payloads
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01W7qG9aFyPij5uWsyAJCxDW
1 parent a51cd93 commit cfafcf1

4 files changed

Lines changed: 12123 additions & 14508 deletions

File tree

‎crates/executor/tests/promql_binary.rs‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -394,6 +394,7 @@ fn stored_series_evaluations_support_filters_and_sets() {
394394
},
395395
),
396396
},
397+
kept: false,
397398
output_state: if id < 2 {
398399
ExecutionDataState::INGESTION_SUMMARY
399400
} else {

‎crates/integration-tests/tests/planner_layering_common/mod.rs‎

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -790,7 +790,12 @@ pub fn retention_ms(p: &Physical, node: PhysicalASAPNodeId) -> Option<u64> {
790790
.dag
791791
.consumers(node)
792792
.into_iter()
793-
.filter(|&c| matches!(p.dag.payload(c), Operator::ASAP(ASAPOp::SummaryMerge { .. })))
793+
.filter(|&c| {
794+
matches!(
795+
p.dag.payload(c),
796+
Operator::ASAP(ASAPOp::SummaryMerge { .. })
797+
)
798+
})
794799
.map(|merge| p.dag.producers(merge).len() as u64 * window(node))
795800
.max();
796801
}

0 commit comments

Comments
 (0)