refactor: adopt precompute/query_time vocabulary from #783

Rebasing onto #783 left code added by this branch on the old names
(ResidualQueryOperator, query_plan::residual, MaintenanceDagSink,
MAINTENANCE_DAG_SCHEMA_VERSION). Apply the same renames, and keep the
backend subDAG scheduler deleted as this branch intends.

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>

Author: zzylol

control_plane/src/physical/plan_dot.rs

@@ -197,7 +197,9 @@ fn query_node_label(node: &QueryPlanNode) -> String {
                 })
                 .unwrap_or_else(|_| "Invalid physical DAG".into())
         }
-        QueryPlanNode::Logical { operator, .. } => format!("Logical\n{}", query_time_label(operator)),
+        QueryPlanNode::Logical { operator, .. } => {
+            format!("Logical\n{}", query_time_label(operator))
+        }
         QueryPlanNode::Scalar { value } => format!("Scalar\n{value}"),
         QueryPlanNode::Binary { operator, .. } => format!("Binary\n{operator:?}"),
         QueryPlanNode::ReduceSum { .. } => "ReduceSum".into(),

control_plane/src/physical/workload_cost.rs

@@ -1091,7 +1091,7 @@ mod tests {
             .all(|entry| entry.nodes.values().any(|node| matches!(
                 node,
                 crate::query_plan::QueryPlanNode::Logical {
-                    operator: crate::query_plan::residual::ResidualQueryOperator::CurrentSeries {
+                    operator: crate::query_plan::query_time::QueryTimeOperator::CurrentSeries {
                         readout: asap_types::query_plan::current_series::SeriesReadout::Count,
                         ..
                     },

control_plane/src/query_plan.rs

@@ -3,7 +3,7 @@
 
 mod clickhouse_exact;
 pub mod physical_values;
-pub mod residual;
+pub mod query_time;
 
 pub use asap_types::query_plan::*;
 #[cfg(test)]

control_plane/src/query_plan/physical_values.rs

@@ -5,7 +5,7 @@ use planner_types::{
     post_asap::BinaryOperator,
     pre_asap::{AggIntent, ArithmeticOpKind, BinaryOpKind, ColumnRef, CompareOpKind, GroupKeys},
 };
-use residual::{Aggregation, BinaryOperation, Grouping, ResidualQueryOperator as Operation};
+use query_time::{Aggregation, BinaryOperation, Grouping, QueryTimeOperator as Operation};
 
 fn invalid(error: impl std::fmt::Display) -> QueryPlanError {
     QueryPlanError::Invalid(error.to_string())
@@ -132,7 +132,7 @@ pub fn compile(
                     Some(physical::compile_limit(*n, *offset, &grouping(groups)).map_err(invalid)?)
                 }
                 Operation::Temporal { operation } => {
-                    use residual::TemporalOperation as T;
+                    use query_time::TemporalOperation as T;
                     let intent = match operation {
                         T::Rate => AggIntent::Rate,
                         T::Increase => AggIntent::Increase,

crates/asap_types/src/executable_plan.rs

@@ -194,8 +194,7 @@ impl InstalledPostAsapDag {
         if self.document.schema_version != PRECOMPUTE_DAG_SCHEMA_VERSION {
             return Err("unsupported maintenance DAG document version".into());
         }
-        self.binding
-            .validate_precompute(&self.document.decode()?)?;
+        self.binding.validate_precompute(&self.document.decode()?)?;
         for sink in self.native_programs.keys() {
             self.native_program(*sink)?;
         }
@@ -504,7 +503,7 @@ mod tests {
         let encoded: serde_json::Value =
             serde_json::from_slice(&program.encode().unwrap()).unwrap();
         let mut document = OwnedPostAsapDag::from_executable("shared".into(), &dag).unwrap();
-        document.schema_version = MAINTENANCE_DAG_SCHEMA_VERSION;
+        document.schema_version = PRECOMPUTE_DAG_SCHEMA_VERSION;
         let mut installed = InstalledPostAsapDag {
             document,
             native_programs: BTreeMap::from([

crates/asap_types/src/query_plan.rs

@@ -7,7 +7,7 @@
 
 pub mod current_series;
 mod native;
-pub mod residual;
+pub mod query_time;
 
 use std::collections::{BTreeMap, BTreeSet};
 

crates/asap_types/src/query_plan/native.rs

@@ -11,7 +11,7 @@ impl QueryPlanEntry {
         match self.nodes.get(&self.root) {
             Some(QueryPlanNode::Logical {
                 operator:
-                    residual::ResidualQueryOperator::CurrentSeries {
+                    query_time::QueryTimeOperator::CurrentSeries {
                         population,
                         readout: current_series::SeriesReadout::Snapshot,
                     },

data_plane/src/precompute_engine/native_precompute.rs

@@ -267,7 +267,7 @@ mod tests {
         let definition = asap_types::sds::StoredOutputId(1);
         let installed = InstalledPostAsapDag {
             document: OwnedPostAsapDag {
-                schema_version: asap_types::executable_plan::MAINTENANCE_DAG_SCHEMA_VERSION,
+                schema_version: asap_types::executable_plan::PRECOMPUTE_DAG_SCHEMA_VERSION,
                 query_id: "shared".into(),
                 nodes: vec![],
                 edges: vec![],