add-integration-test

Signed-off-by: Vanshika Vanshika <vvanshik@redhat.com>

rh-pre-commit.version: 2.3.2
rh-pre-commit.check-secrets: ENABLED

Author: Vperiodt

sdk/python/feast/feature_store.py

@@ -254,9 +254,7 @@ def _init_mlflow_tracking(self):
     def _rebuild_fs_name_index(self) -> None:
         """Rebuild the {frozenset(refs) → service_name} index from the registry."""
         index: Dict[frozenset, str] = {}
-        for fs in self.registry.list_feature_services(
-            self.project, allow_cache=True
-        ):
+        for fs in self.registry.list_feature_services(self.project, allow_cache=True):
             fs_refs = frozenset(
                 f"{p.name}:{f.name}"
                 for p in fs.feature_view_projections

sdk/python/feast/mlflow_integration/logger.py

@@ -54,10 +54,11 @@ def _report_failure(msg: str, exc: Exception) -> None:
     global _consecutive_failures, _last_warning_time
     _consecutive_failures += 1
     now = time.monotonic()
-    if _consecutive_failures == 1 or (now - _last_warning_time) >= _WARNING_INTERVAL_SECONDS:
-        _logger.warning(
-            "%s (failures=%d): %s", msg, _consecutive_failures, exc
-        )
+    if (
+        _consecutive_failures == 1
+        or (now - _last_warning_time) >= _WARNING_INTERVAL_SECONDS
+    ):
+        _logger.warning("%s (failures=%d): %s", msg, _consecutive_failures, exc)
         _last_warning_time = now
     else:
         _logger.debug("%s (failures=%d): %s", msg, _consecutive_failures, exc)