Method run

control_layer.py:876–1022

(
        self,
        user_input: str,
        constraints: Optional[List[str]] = None,
        context: str = "",
    )

        self.fallback_router.register(name, fn)

    def run(
        self,
        user_input: str,
        constraints: Optional[List[str]] = None,
        context: str = "",
    ) -> ControlPacket:
        constraints = constraints or []
        audit_id = self._make_audit_id(user_input)
        start = time.perf_counter()

        # ── Input Guard ────────────────────────────────────────────────────
        guard_result = self.input_guard.validate(user_input)
        if not guard_result.passed:
            self._log_record(audit_id, 0, guard_result, 0.0, 0, RetryStrategy.NONE)
            log.warning(
                "input_guard.blocked",
                failure_mode=guard_result.failure_mode.value,
                message=guard_result.message[:80],
            )
            return self._packet("", "", 0, start, guard_result,
                                TokenBudget(self.config.total_tokens, self.config.model_name),
                                RetryStrategy.NONE, audit_id)

        user_input = self.input_guard.sanitize(user_input)

        # ── Circuit Breaker ────────────────────────────────────────────────
        if self.circuit_breaker.is_open():
            result = ValidationResult(
                passed=False,
                failure_mode=FailureMode.CIRCUIT_OPEN,
                message="Circuit breaker is open. LLM backend unavailable.",
                score=0.0,
            )
            self._log_record(audit_id, 0, result, 0.0, 0, RetryStrategy.NONE)
            log.error("circuit_breaker.rejected", audit_id=audit_id)
            return self._packet("", "", 0, start, result,
                                TokenBudget(self.config.total_tokens, self.config.model_name),
                                RetryStrategy.NONE, audit_id)

        mutation_hint  = ""
        last_validation = ValidationResult(passed=False)
        last_budget    = TokenBudget(self.config.total_tokens, self.config.model_name)
        attempt        = 0

        # ── Retry Loop ─────────────────────────────────────────────────────
        for attempt in range(1, self.config.max_attempts + 1):
            prompt, budget = self.prompt_builder.build(
                user_input, constraints, context, mutation_hint
            )
            last_budget = budget

            t0 = time.perf_counter()
            try:
                response = self.llm_caller.call(prompt)
                self.circuit_breaker.record_success()
            except LLMTimeoutError as exc:
                call_latency_ms = (time.perf_counter() - t0) * 1000
                self.circuit_breaker.record_failure()