@@ -0,0 +98,4 @@
+        # Re-apply global defaults for any services that were introduced
+        # by _apply_config_overrides but were not in the registry when
+        # _apply_settings_defaults first ran.
+        self._apply_settings_defaults(settings)

@@ -0,0 +102,4 @@
+
+        # Pre-create circuit breakers and cache wait strategies for all
+        # registered services so that execute() avoids per-call allocation.
+        for name in self._registry.registered_services():

@@ -0,0 +187,4 @@
+            try:
+                logger.warning(
+                    "Invalid retry_service_overrides JSON — ignoring",
+                    raw=raw,

@@ -0,0 +303,4 @@
+                    try:
+                        if cb is not None:
+                            return cb.call(func, *args, **kwargs)
+                        return func(*args, **kwargs)

@@ -0,0 +61,4 @@
+        self._half_open_permits = 0
+        self._last_half_open_time: float | None = None
+        self._lock = threading.Lock()
+        self._async_lock = asyncio.Lock()

@@ -0,0 +84,4 @@
+
+        try:
+            result = func(*args, **kwargs)
+        except self.expected_exception:

@@ -0,0 +91,4 @@
+        return wait_exponential(
+            multiplier=effective_delay, min=effective_delay, max=max_delay
+        )
+    if strategy == "linear":

@@ -0,0 +288,4 @@
+    phase = kwargs.get("plan_phase", "")
+    if not isinstance(phase, str):
+        return False
+    if phase.lower() in ("execute", "apply"):

@@ -0,0 +435,4 @@
+                                error=_sanitize_error_message(debug_error),
+                            )
+
+                await asyncio.sleep(2**attempt)

@@ -0,0 +385,4 @@
+        same instance without re-allocation.
+        """
+        if service_name in self._policies:
+            return self._policies[service_name]

@@ -0,0 +462,4 @@
+                    merged[key] = override_data[key]
+            try:
+                self._policies[service_name] = ServiceRetryPolicy.model_validate(merged)
+            except ValidationError:

@@ -0,0 +271,4 @@
+            return func(*args, **kwargs)
+
+        # Guard against retry amplification in nested service calls
+        depth = _retry_depth.get()

@@ -0,0 +84,4 @@
+
+        try:
+            result = func(*args, **kwargs)
+        except self.expected_exception:

@@ -0,0 +163,4 @@
+        """Check if enough time has passed to attempt reset."""
+        if self.last_failure_time is None:
+            return False
+        now = time.time()

@@ -0,0 +84,4 @@
+    jitter: bool,
+) -> Any:
+    """Build a tenacity wait strategy from config values."""
+    if strategy == "exponential":

@@ -0,0 +320,4 @@
+    ) -> bool:
+        if exc_type:
+            self.errors.append(exc_val)
+            logger.warning(

@@ -0,0 +435,4 @@
+                                error=_sanitize_error_message(debug_error),
+                            )
+
+                await asyncio.sleep(2**attempt)