style: auto-format code with ruff

Author: open-resource-broker-cicd[bot]

tests/unit/api/middleware/test_audit_log_middleware.py

@@ -17,6 +17,7 @@
 # helpers
 # ---------------------------------------------------------------------------
 
+
 def _make_app_with_middleware():
     """Return a minimal FastAPI app with AuditLogMiddleware attached."""
     app = FastAPI()
@@ -57,9 +58,9 @@ async def create_request():
 # dispatch matrix tests
 # ---------------------------------------------------------------------------
 
+
 @pytest.mark.unit
 class TestAuditLogMiddlewareDispatch:
-
     def test_get_non_audit_prefix_not_audited(self, caplog):
         """A plain GET not matching AUDIT_ALWAYS_PREFIXES is skipped."""
         app = _make_app_with_middleware()
@@ -133,9 +134,9 @@ def test_health_path_not_audited(self, caplog):
 # audit log fields
 # ---------------------------------------------------------------------------
 
+
 @pytest.mark.unit
 class TestAuditLogFields:
-
     def test_latency_ms_present_in_log(self, caplog):
         app = _make_app_with_middleware()
         client = TestClient(app)
@@ -198,9 +199,9 @@ def test_method_and_path_recorded(self, caplog):
 # latency monotonic semantics
 # ---------------------------------------------------------------------------
 
+
 @pytest.mark.unit
 class TestAuditLogLatencySemantics:
-
     def test_latency_uses_monotonic_clock(self, caplog):
         """Latency must be measured with time.monotonic, not wall clock."""
         app = _make_app_with_middleware()

tests/unit/api/middleware/test_read_only_middleware.py

@@ -13,6 +13,7 @@
 # helpers
 # ---------------------------------------------------------------------------
 
+
 def _make_app(enabled: bool):
     """Return a FastAPI app with ReadOnlyMiddleware configured."""
     app = FastAPI()
@@ -49,9 +50,9 @@ async def health_post():
 # Enabled + mutating → 403
 # ---------------------------------------------------------------------------
 
+
 @pytest.mark.unit
 class TestReadOnlyMiddlewareEnabled:
-
     def test_post_is_blocked_when_enabled(self):
         client = TestClient(_make_app(enabled=True), raise_server_exceptions=True)
         resp = client.post("/api/v1/machines")
@@ -74,9 +75,9 @@ def test_post_to_request_blocked(self):
 # Enabled + safe verb → passes
 # ---------------------------------------------------------------------------
 
+
 @pytest.mark.unit
 class TestReadOnlyMiddlewareSafeVerbs:
-
     def test_get_passes_when_enabled(self):
         client = TestClient(_make_app(enabled=True))
         resp = client.get("/api/v1/machines")
@@ -92,9 +93,9 @@ def test_get_returns_normal_body(self):
 # Enabled + allowed path → passes
 # ---------------------------------------------------------------------------
 
+
 @pytest.mark.unit
 class TestReadOnlyMiddlewareAllowedPaths:
-
     def test_post_health_passes_when_enabled(self):
         client = TestClient(_make_app(enabled=True))
         resp = client.post("/health")
@@ -117,9 +118,9 @@ def test_post_reflex_upload_prefix_passes(self):
 # Disabled + mutating → passes
 # ---------------------------------------------------------------------------
 
+
 @pytest.mark.unit
 class TestReadOnlyMiddlewareDisabled:
-
     def test_post_passes_when_disabled(self):
         client = TestClient(_make_app(enabled=False))
         resp = client.post("/api/v1/machines")
@@ -135,9 +136,9 @@ def test_get_passes_when_disabled(self):
 # Allowed path constants
 # ---------------------------------------------------------------------------
 
+
 @pytest.mark.unit
 class TestAllowedPathConstants:
-
     def test_event_path_in_allowed_paths(self):
         assert "/_event" in _ALLOWED_PATHS
 

tests/unit/application/services/orchestration/test_dashboard_summary.py

@@ -22,6 +22,7 @@
 # helpers
 # ---------------------------------------------------------------------------
 
+
 def _make_uow(
     *,
     machine_by_status=None,
@@ -65,8 +66,9 @@ def _make_list_requests_orchestrator(requests=None):
     return orch
 
 
-def _make_orchestrator(*, machine_by_status=None, request_by_status=None,
-                        provider_api_counts=None, requests=None):
+def _make_orchestrator(
+    *, machine_by_status=None, request_by_status=None, provider_api_counts=None, requests=None
+):
     uow = _make_uow(
         machine_by_status=machine_by_status,
         request_by_status=request_by_status,
@@ -86,6 +88,7 @@ def _make_orchestrator(*, machine_by_status=None, request_by_status=None,
 # _to_iso helper
 # ---------------------------------------------------------------------------
 
+
 @pytest.mark.unit
 class TestToIso:
     def test_none_returns_none(self):
@@ -116,10 +119,10 @@ def test_other_type_coerced_to_str(self):
 # DashboardSummaryOrchestrator.execute
 # ---------------------------------------------------------------------------
 
+
 @pytest.mark.unit
 @pytest.mark.application
 class TestDashboardSummaryOrchestrator:
-
     @pytest.mark.asyncio
     async def test_happy_path_aggregates_all_sections(self):
         """All three sections must be populated from the UoW repos."""
@@ -169,8 +172,14 @@ async def test_well_known_keys_present_even_when_count_is_zero(self):
         for key in ("running", "pending", "stopped", "terminated", "shutting-down"):
             assert key in result.machines["by_status"]
         for key in (
-            "pending", "in_progress", "acquiring", "complete",
-            "failed", "partial", "cancelled", "timeout",
+            "pending",
+            "in_progress",
+            "acquiring",
+            "complete",
+            "failed",
+            "partial",
+            "cancelled",
+            "timeout",
         ):
             assert key in result.requests["by_status"]
         for key in ("aws", "EC2Fleet", "SpotFleet", "RunInstances", "ASG"):
@@ -211,10 +220,24 @@ async def test_recent_activity_capped_at_10(self):
     async def test_recent_activity_sorted_by_created_at_desc(self):
         """Most recently created requests appear first."""
         requests = [
-            {"request_id": "old", "created_at": "2024-01-01T00:00:00+00:00", "status": "complete",
-             "request_type": "acquire", "template_id": "", "successful_count": 0, "requested_count": 0},
-            {"request_id": "new", "created_at": "2024-06-01T00:00:00+00:00", "status": "complete",
-             "request_type": "acquire", "template_id": "", "successful_count": 0, "requested_count": 0},
+            {
+                "request_id": "old",
+                "created_at": "2024-01-01T00:00:00+00:00",
+                "status": "complete",
+                "request_type": "acquire",
+                "template_id": "",
+                "successful_count": 0,
+                "requested_count": 0,
+            },
+            {
+                "request_id": "new",
+                "created_at": "2024-06-01T00:00:00+00:00",
+                "status": "complete",
+                "request_type": "acquire",
+                "template_id": "",
+                "successful_count": 0,
+                "requested_count": 0,
+            },
         ]
         orchestrator = _make_orchestrator(requests=requests)
         result = await orchestrator.execute(DashboardSummaryInput())
@@ -225,12 +248,23 @@ async def test_recent_activity_sorted_by_created_at_desc(self):
     async def test_recent_activity_missing_created_at_lands_at_end(self):
         """Rows without created_at must sort to the end (after dated rows)."""
         requests = [
-            {"request_id": "has-date", "created_at": "2024-03-01T00:00:00+00:00",
-             "status": "complete", "request_type": "acquire", "template_id": "",
-             "successful_count": 0, "requested_count": 0},
-            {"request_id": "no-date", "status": "pending",
-             "request_type": "acquire", "template_id": "",
-             "successful_count": 0, "requested_count": 0},
+            {
+                "request_id": "has-date",
+                "created_at": "2024-03-01T00:00:00+00:00",
+                "status": "complete",
+                "request_type": "acquire",
+                "template_id": "",
+                "successful_count": 0,
+                "requested_count": 0,
+            },
+            {
+                "request_id": "no-date",
+                "status": "pending",
+                "request_type": "acquire",
+                "template_id": "",
+                "successful_count": 0,
+                "requested_count": 0,
+            },
         ]
         orchestrator = _make_orchestrator(requests=requests)
         result = await orchestrator.execute(DashboardSummaryInput())
@@ -303,9 +337,7 @@ async def test_count_by_status_called_on_machines_and_requests_repos(self):
     @pytest.mark.asyncio
     async def test_count_by_provider_api_returns_real_values(self):
         """count_by_provider_api values flow into templates section."""
-        orchestrator = _make_orchestrator(
-            provider_api_counts={"EC2Fleet": 7, "RunInstances": 3}
-        )
+        orchestrator = _make_orchestrator(provider_api_counts={"EC2Fleet": 7, "RunInstances": 3})
         result = await orchestrator.execute(DashboardSummaryInput())
         assert result.templates["by_provider_api"]["EC2Fleet"] == 7
         assert result.templates["by_provider_api"]["RunInstances"] == 3
@@ -315,8 +347,14 @@ async def test_count_by_provider_api_returns_real_values(self):
     async def test_request_id_fallback_to_id_field(self):
         """If 'request_id' absent, 'id' is used instead."""
         requests = [
-            {"id": "fallback-id", "status": "pending", "request_type": "acquire",
-             "template_id": "", "successful_count": 0, "requested_count": 0}
+            {
+                "id": "fallback-id",
+                "status": "pending",
+                "request_type": "acquire",
+                "template_id": "",
+                "successful_count": 0,
+                "requested_count": 0,
+            }
         ]
         orchestrator = _make_orchestrator(requests=requests)
         result = await orchestrator.execute(DashboardSummaryInput())

tests/unit/infrastructure/storage/test_safe_deserialize_iter.py

@@ -13,6 +13,7 @@
 # Concrete subclass for testing
 # ---------------------------------------------------------------------------
 
+
 class _ConcreteRepo(StorageRepositoryMixin):
     """Minimal concrete repo that uses _safe_deserialize_iter."""
 
@@ -34,9 +35,9 @@ def _get_storage(self):
 # _safe_deserialize_iter tests
 # ---------------------------------------------------------------------------
 
+
 @pytest.mark.unit
 class TestSafeDeserializeIter:
-
     def test_all_valid_rows_returned(self):
         rows = [
             {"machine_id": "m1", "status": "running"},
@@ -70,6 +71,7 @@ def flaky(data):
 
     def test_error_log_emitted_with_entity_id(self):
         """logger.error must be called with the entity id of the bad row."""
+
         def broken(_data):
             raise ValueError("schema changed")
 
@@ -135,6 +137,7 @@ def always_fail(_data):
 
     def test_unknown_entity_type_counted_under_unknown(self):
         """Rows with no known id field go into 'unknown' bucket."""
+
         def broken(_data):
             raise ValueError("bad")
 
@@ -147,6 +150,7 @@ def broken(_data):
 
     def test_skip_counter_accumulates_across_calls(self):
         """Multiple calls to _safe_deserialize_iter must accumulate skip counts."""
+
         def broken(_data):
             raise ValueError("bad")
 
@@ -158,6 +162,7 @@ def broken(_data):
 
     def test_error_logged_at_error_level(self):
         """Skipped rows must be logged at ERROR level (not WARNING/INFO)."""
+
         def broken(_data):
             raise ValueError("validation")