Skip to content

Commit cf6650c

Browse files
committed
Merge branch 'integration/physical-stack-765' into integration/physical-stack-766
2 parents 999cafd + 26326a8 commit cf6650c

61 files changed

Lines changed: 681 additions & 594 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎Cargo.lock‎

Lines changed: 12 additions & 11 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎Cargo.toml‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -14,10 +14,10 @@ version = "0.1.0"
1414
[workspace.dependencies]
1515
# Keep Planner frontends, selection, and IR on the same immutable revision.
1616
# Alias upstream asap-types because this workspace also defines asap_types.
17-
planner-types = { package = "asap-types", git = "https://github.com/ProjectASAP/ASAPPlanner", rev = "645cacb04a451e25147f0d23aaddd05da16b4746" }
18-
asap-aware-mapping = { git = "https://github.com/ProjectASAP/ASAPPlanner", rev = "645cacb04a451e25147f0d23aaddd05da16b4746" }
19-
asap-frontend-promql = { git = "https://github.com/ProjectASAP/ASAPPlanner", rev = "645cacb04a451e25147f0d23aaddd05da16b4746" }
20-
asap-frontend-sql = { git = "https://github.com/ProjectASAP/ASAPPlanner", rev = "645cacb04a451e25147f0d23aaddd05da16b4746" }
17+
planner-types = { package = "asap-types", git = "https://github.com/ProjectASAP/ASAPPlanner", rev = "b58f24268270a4dd7b7caaf0076ea3db842f3e9b" }
18+
asap-aware-mapping = { git = "https://github.com/ProjectASAP/ASAPPlanner", rev = "b58f24268270a4dd7b7caaf0076ea3db842f3e9b" }
19+
asap-frontend-promql = { git = "https://github.com/ProjectASAP/ASAPPlanner", rev = "b58f24268270a4dd7b7caaf0076ea3db842f3e9b" }
20+
asap-frontend-sql = { git = "https://github.com/ProjectASAP/ASAPPlanner", rev = "b58f24268270a4dd7b7caaf0076ea3db842f3e9b" }
2121

2222
# Shared external deps (used by 2+ crates)
2323
serde = { version = "1.0", features = ["derive"] }
@@ -37,8 +37,8 @@ arc-swap = "1.7"
3737
reqwest = { version = "0.12", default-features = false, features = ["json", "rustls-tls"] }
3838

3939
# Internal crates
40-
asap-physical-operators = { git = "https://github.com/ProjectASAP/ASAPPlanner", rev = "645cacb04a451e25147f0d23aaddd05da16b4746" }
41-
asap_sketch_codec = { git = "https://github.com/ProjectASAP/ASAPPlanner", rev = "645cacb04a451e25147f0d23aaddd05da16b4746" }
40+
asap-physical-operators = { git = "https://github.com/ProjectASAP/ASAPPlanner", rev = "b58f24268270a4dd7b7caaf0076ea3db842f3e9b" }
41+
asap_sketch_codec = { git = "https://github.com/ProjectASAP/ASAPPlanner", rev = "b58f24268270a4dd7b7caaf0076ea3db842f3e9b" }
4242
asap_types = { path = "crates/asap_types" }
4343
asap_otel_proto = { path = "crates/asap_otel_proto" }
4444
indexmap = { version = "2.0", features = ["serde"] }

‎control_plane/examples/calibration_candidates.rs‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
//! Export every bindable candidate for isolated measurement, without selecting a winner.
22
use control_plane::physical::{
3-
compiler::{BackendLocalPlanningInput, PhysicalPlanCompiler},
3+
compiler::{BackendLocalPlanningInput, DeploymentPlanCompiler},
44
workload_cost,
55
};
66
use planner_types::post_asap::{SummaryExpr, SummaryNode};
@@ -129,9 +129,9 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
129129
let enabled_materialization_keys = candidate.enabled_materialization_keys.clone();
130130
let planner_selected_queries = planner_forest(&queries);
131131
let compiled = if metricsql {
132-
PhysicalPlanCompiler.compile_metricsql(candidate, environment.clone())
132+
DeploymentPlanCompiler.compile_metricsql(candidate, environment.clone())
133133
} else {
134-
PhysicalPlanCompiler.compile_promql(candidate, environment.clone())
134+
DeploymentPlanCompiler.compile_promql(candidate, environment.clone())
135135
};
136136
let plan = match compiled {
137137
Ok(plan) => plan,

‎control_plane/examples/workload_cost_manifest.rs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
//! Emit pricing requirements; never fabricate quotes or publish a plan.
22
use control_plane::physical::{
3-
compiler::BackendLocalPlanningInput, compiler::PhysicalPlanCompiler, workload_cost,
3+
compiler::BackendLocalPlanningInput, compiler::DeploymentPlanCompiler, workload_cost,
44
};
55

66
fn main() -> Result<(), Box<dyn std::error::Error>> {
@@ -14,7 +14,7 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
1414
.into_iter()
1515
.filter_map(|candidate| {
1616
let queries = candidate.queries.clone();
17-
PhysicalPlanCompiler
17+
DeploymentPlanCompiler
1818
.compile_promql(candidate, environment.clone())
1919
.and_then(|plan| workload_cost::manifest(&plan, &queries))
2020
.ok()

‎control_plane/src/physical/backend_stage.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
//! Backend-facing projection of one planning cycle.
22
//!
33
//! These types are the input to [`crate::backend_plan::from_stage_config`] and
4-
//! to `emit::backend_wire`'s backend JSON builders. `PhysicalPlanCompiler` builds
4+
//! to `emit::backend_wire`'s backend JSON builders. `DeploymentPlanCompiler` builds
55
//! them directly from the summaries ASAPPlanner selected.
66
//!
77
//! They are deliberately not `Serialize`/`Deserialize`: `SummaryFamilyType`

0 commit comments

Comments
 (0)