Fixed lint errors & minor formatting

Signed-off-by: Aniket Paluskar <apaluska@redhat.com>
aniketpalu · Jul 8, 2026 · Jul 8, 2026 · Jul 8, 2026 · Jul 8, 2026 · Jul 10, 2026
commit 82ce777cd4e082bbc1ca6945d32ea1c10e0039d5
@@ -2295,9 +2295,7 @@ def on_change(result: FVResult):
         failed = [r for r in results if r.status == FVMaterializationStatus.FAILED]
         if failed:
             names = ", ".join(r.name for r in failed)
-            errors = "; ".join(
-                f"{r.name}: {r.error}" for r in failed if r.error
-            )
+            errors = "; ".join(f"{r.name}: {r.error}" for r in failed if r.error)
             msg = f"Remote materialization failed for: {names}"
             if errors:
                 msg += f" ({errors})"
@@ -2381,9 +2379,7 @@ def on_change(result: FVResult):
         failed = [r for r in results if r.status == FVMaterializationStatus.FAILED]
         if failed:
             names = ", ".join(r.name for r in failed)
-            errors = "; ".join(
-                f"{r.name}: {r.error}" for r in failed if r.error
-            )
+            errors = "; ".join(f"{r.name}: {r.error}" for r in failed if r.error)
             msg = f"Remote incremental materialization failed for: {names}"
             if errors:
                 msg += f" ({errors})"

diff --git a/sdk/python/feast/materialization_status.py b/sdk/python/feast/materialization_status.py
@@ -1,6 +1,6 @@
 import logging
 import time
-from dataclasses import dataclass, field
+from dataclasses import dataclass
 from enum import Enum
 from typing import Callable, Dict, List, Optional, Set
 
@@ -67,9 +67,7 @@ def poll_materialization_status(
             elapsed = time.monotonic() - start
 
             if current != previous_statuses.get(name):
-                result = FVResult(
-                    name=name, status=current, elapsed_seconds=elapsed
-                )
+                result = FVResult(name=name, status=current, elapsed_seconds=elapsed)
                 results[name] = result
                 previous_statuses[name] = current
                 if on_status_change:

diff --git a/sdk/python/tests/unit/test_remote_materialize.py b/sdk/python/tests/unit/test_remote_materialize.py
@@ -1,21 +1,17 @@
 """Tests for remote materialization: shared poller, client-side delegation, and async endpoints."""
 
-import time
-from datetime import datetime, timedelta, timezone
+from datetime import datetime, timezone
 from unittest.mock import MagicMock, patch
 
 import pytest
 from fastapi.testclient import TestClient
 
 from feast.feature_server import get_app
-from feast.feature_view import FeatureViewState
 from feast.materialization_status import (
     FVMaterializationStatus,
-    FVResult,
     poll_materialization_status,
 )
 
-
 # ---------------------------------------------------------------------------
 # Tests for poll_materialization_status
 # ---------------------------------------------------------------------------
@@ -39,7 +35,10 @@ def status_fn(name):
 
     def test_mixed_results(self):
         """One FV succeeds, one fails."""
-        statuses = {"fv_a": FVMaterializationStatus.SUCCEEDED, "fv_b": FVMaterializationStatus.FAILED}
+        statuses = {
+            "fv_a": FVMaterializationStatus.SUCCEEDED,
+            "fv_b": FVMaterializationStatus.FAILED,
+        }
 
         def status_fn(name):
             return statuses[name]
@@ -235,8 +234,6 @@ def test_materialize_delegates_when_remote_mode(self, mock_remote):
         fs.config.feature_server.materialize_mode = "remote"
         fs.config.feature_server.url = "http://feast-server:80"
 
-        from feast.feature_store import FeatureStore
-
         # Call the unbound method with our mock self
         fs._is_remote_materialize_mode = MagicMock(return_value=True)
         fs._remote_materialize = MagicMock()

diff --git a/sdk/python/tests/unit/test_remote_materialize_e2e.py b/sdk/python/tests/unit/test_remote_materialize_e2e.py
@@ -6,12 +6,9 @@
   FV state transitions → client polls registry → returns success
 """
 
-import os
-import tempfile
 import threading
 import time
 from datetime import datetime, timedelta, timezone
-from pathlib import Path
 
 import pandas as pd
 import pytest