feat(planner): AIC closed-loop optimizer

components/src/dynamo/planner/config/defaults.py

@@ -116,6 +116,20 @@ class SLAPlannerDefaults(BasePlannerDefaults):
     decode_engine_gpu_power_limit: int = 300  # watts per GPU, decode replicas
     power_agent_safe_default_watts: Optional[int] = None
 
+    # AIC optimizer (Phase 3+, disabled by default)
+    enable_aic_optimizer: bool = False
+    aic_reoptimize_interval: int = 300  # seconds between AIC sweeps
+    aic_drift_relative_threshold: float = 0.15  # fraction before re-sweep triggers
+    aic_drift_consecutive_ticks: int = 3  # ticks of sustained signal needed
+    # Cold-start values for per-component power coefficients (Phase 3+).
+    aic_initial_c_power_prefill: float = 1.0
+    aic_initial_c_power_decode: float = 1.0
+    aic_initial_c_power_agg: float = 1.0
+    aic_initial_c_ttft: float = 1.0
+    aic_initial_c_itl: float = 1.0
+    aic_max_consecutive_failures: int = 5
+    aic_throughput_regression_warn_threshold: float = 0.10
+
 
 class SubComponentType(str, Enum):
     PREFILL = "prefill"

components/src/dynamo/planner/config/planner_config.py

@@ -283,6 +283,85 @@ class PlannerConfig(BaseModel):
         ),
     )
 
+    # --- AIC optimizer (Phase 3+) ---
+    enable_aic_optimizer: bool = Field(default=False)
+    aic_system: Optional[str] = Field(
+        default=None,
+        description="AIC system identifier (e.g. 'h200_sxm'). Falls back to aic_interpolation.system.",
+    )
+    aic_reoptimize_interval: int = Field(
+        default=SLAPlannerDefaults.aic_reoptimize_interval
+    )
+    aic_drift_relative_threshold: float = Field(
+        default=SLAPlannerDefaults.aic_drift_relative_threshold, ge=0.0
+    )
+    aic_drift_consecutive_ticks: int = Field(
+        default=SLAPlannerDefaults.aic_drift_consecutive_ticks, ge=1
+    )
+    aic_initial_c_power_prefill: float = Field(
+        default=SLAPlannerDefaults.aic_initial_c_power_prefill,
+        description="Cold-start c_power_p (disagg prefill side). H200 dense: ~1.05.",
+    )
+    aic_initial_c_power_decode: float = Field(
+        default=SLAPlannerDefaults.aic_initial_c_power_decode,
+        description="Cold-start c_power_d (disagg decode side). H200 dense: ~1.15.",
+    )
+    aic_initial_c_power_agg: float = Field(
+        default=SLAPlannerDefaults.aic_initial_c_power_agg,
+        description="Cold-start c_power_agg (aggregated mode only).",
+    )
+    aic_initial_c_ttft: float = Field(
+        default=SLAPlannerDefaults.aic_initial_c_ttft,
+        description="Cold-start c_ttft before live data arrives.",
+    )
+    aic_initial_c_itl: float = Field(
+        default=SLAPlannerDefaults.aic_initial_c_itl,
+        description="Cold-start c_itl before live data arrives.",
+    )
+    aic_max_consecutive_failures: int = Field(
+        default=SLAPlannerDefaults.aic_max_consecutive_failures, ge=1
+    )
+    aic_throughput_regression_warn_threshold: float = Field(
+        default=SLAPlannerDefaults.aic_throughput_regression_warn_threshold,
+        ge=0.0,
+        le=1.0,
+    )
+
+    # --- Frontend admission coupling (Phase 3+) ---
+    admission_mode: Literal["off", "inherit", "autoset"] = Field(
+        default="off",
+        description=(
+            "Frontend /busy_threshold coupling. 'off' never POSTs; 'inherit' "
+            "computes implied thresholds and emits Prometheus gauges only; "
+            "'autoset' POSTs implied thresholds after every config change."
+        ),
+    )
+    admission_safety_margin: float = Field(
+        default=1.0,
+        ge=0.0,
+        le=1.0,
+        description=(
+            "Multiplier applied to implied thresholds before POST in autoset mode. "
+            "Lower values shed earlier (more headroom for queueing variance)."
+        ),
+    )
+    frontend_http_port: int = Field(
+        default=8000,
+        ge=1,
+        le=65535,
+        description=(
+            "Legacy fallback port for /busy_threshold POST in autoset "
+            "admission mode. The planner now reads each frontend pod's "
+            "actual HTTP port from V1Pod.spec.containers[].ports[name=http] "
+            "(emitted by the operator since v1.x — see "
+            "deploy/operator/internal/consts/consts.go DynamoContainerPortName). "
+            "This config field is consulted only when the named port is "
+            "missing from the pod spec, which covers hand-rolled DGDs and "
+            "manifests authored before the operator's named-port standardization. "
+            "Default 8000 matches the operator's DynamoServicePort."
+        ),
+    )
+
     # Diagnostics report settings
     report_interval_hours: Optional[float] = Field(
         default=24.0,
@@ -358,6 +437,23 @@ def _validate_config(self) -> "PlannerConfig":
                     "(e.g. 500W on H200 SXM)."
                 )
 
+        # AIC optimizer validation (Phase 3)
+        if self.enable_aic_optimizer:
+            if self.aic_interpolation is None:
+                raise ValueError(
+                    "enable_aic_optimizer=True requires aic_interpolation to be set. "
+                    "AICInterpolationSpec carries the AIC model/system/backend and the "
+                    "picked TP configs that constrain the optimizer sweep. "
+                    "In rapid mode, the profiler writes this to the planner ConfigMap. "
+                    "See AICInterpolationSpec for required fields."
+                )
+            if not self.enable_power_awareness:
+                raise ValueError(
+                    "enable_aic_optimizer=True requires enable_power_awareness=True. "
+                    "The AIC optimizer derives and applies per-GPU power caps; those "
+                    "caps only take effect when power awareness is enabled."
+                )
+
         if self.environment == "global-planner" and not self.global_planner_namespace:
             raise ValueError(
                 "global_planner_namespace is required when environment='global-planner'. "