style(tests): apply ruff format/lint fixes to pre-existing test files

Picked up by ruff/ruff-format pre-commit hooks while committing unrelated
work; no logic changes — unused imports, blank-line spacing, and line-wrap
formatting only.

Author: YoTro

AWS/tests/integration/test_feishu.py

@@ -11,7 +11,6 @@
 from src.jobs.callbacks.feishu import FeishuCallback
 from src.workflows.engine import WorkflowResult
 
-
 # ---------------------------------------------------------------------------
 # Fixtures
 # ---------------------------------------------------------------------------

AWS/tests/integration/test_monopoly.py

@@ -12,7 +12,6 @@
 from src.workflows.steps.base import ComputeTarget, WorkflowContext
 from src.workflows.steps.process import ProcessStep
 
-
 # ---------------------------------------------------------------------------
 # Fixtures
 # ---------------------------------------------------------------------------
@@ -59,7 +58,11 @@ def test_brand_concentration(self, analyzer):
 
     def test_review_barrier(self, analyzer):
         high = [
-            {"rank": i, "review_count": 10000 if i <= 10 else 100, "rating": 4.6 if i <= 10 else 4.0}
+            {
+                "rank": i,
+                "review_count": 10000 if i <= 10 else 100,
+                "rating": 4.6 if i <= 10 else 4.0,
+            }
             for i in range(1, 60)
         ]
         low = [

AWS/tests/live/test_comments.py

@@ -1,6 +1,5 @@
 from __future__ import annotations
 
-import asyncio
 import logging
 import os
 import sys

AWS/tests/unit/test_calibration.py

@@ -2,8 +2,6 @@
 
 import json
 import os
-import shutil
-import tempfile
 import threading
 
 import pytest
@@ -16,7 +14,6 @@
     save_calibration,
 )
 
-
 # ---------------------------------------------------------------------------
 # Fixtures
 # ---------------------------------------------------------------------------

AWS/tests/unit/test_job_error_mapping.py

@@ -1,8 +1,9 @@
 """Error → callback mapping tests for JobManager._run_job."""
+
 from __future__ import annotations
 
 from contextlib import asynccontextmanager
-from unittest.mock import MagicMock, AsyncMock, patch
+from unittest.mock import AsyncMock, MagicMock, patch
 
 import pytest
 
@@ -11,8 +12,12 @@
 
 class _FakeSlot:
     """Minimal async context manager that does nothing."""
-    async def __aenter__(self): return self
-    async def __aexit__(self, *args): pass
+
+    async def __aenter__(self):
+        return self
+
+    async def __aexit__(self, *args):
+        pass
 
 
 @asynccontextmanager
@@ -44,9 +49,7 @@ def record():
 
 async def _run_job_with_error(mgr, rec, error):
     mgr._jobs[rec.job_id] = rec
-    with patch(
-        "src.gateway.rate_limit.RateLimiter.concurrent_slot", _fake_concurrent_slot
-    ):
+    with patch("src.gateway.rate_limit.RateLimiter.concurrent_slot", _fake_concurrent_slot):
         with patch.object(mgr, "_run_workflow_mode") as mock_run:
             mock_run.side_effect = error
             await mgr._run_job(rec.job_id)
@@ -62,11 +65,15 @@ async def test_maps_to_suspended_not_error(self, manager, record):
         record.callback.on_error = AsyncMock()
 
         await _run_job_with_error(
-            manager, record,
+            manager,
+            record,
             BatchPendingError(
-                "batch submitted", batch_job_id="batch_123",
+                "batch submitted",
+                batch_job_id="batch_123",
                 handle=MagicMock(provider="gemini"),
-                requests=[], items_snapshot=[], output_field="analysis",
+                requests=[],
+                items_snapshot=[],
+                output_field="analysis",
             ),
         )
 
@@ -84,11 +91,15 @@ async def test_notifies_with_batch_id(self, manager, record):
         record.callback.on_progress = AsyncMock()
 
         await _run_job_with_error(
-            manager, record,
+            manager,
+            record,
             BatchPendingError(
-                "batch submitted", batch_job_id="batch_abc",
+                "batch submitted",
+                batch_job_id="batch_abc",
                 handle=MagicMock(provider="gemini"),
-                requests=[], items_snapshot=[], output_field="analysis",
+                requests=[],
+                items_snapshot=[],
+                output_field="analysis",
             ),
         )
 
@@ -104,7 +115,8 @@ async def test_maps_to_failed_with_on_error(self, manager, record):
         record.callback.on_error = AsyncMock()
 
         await _run_job_with_error(
-            manager, record,
+            manager,
+            record,
             RetryableError("rate limited", http_status=429, provider="test"),
         )
 
@@ -120,7 +132,8 @@ async def test_notify_for_concurrent_limit(self, manager, record):
         record.callback.on_error = AsyncMock()
 
         await _run_job_with_error(
-            manager, record,
+            manager,
+            record,
             RuntimeError("concurrent limit reached for entry_type=cli_workflow"),
         )
 

AWS/tests/unit/test_xiyou.py

@@ -9,7 +9,6 @@
 from src.mcp.servers.market.tools import handle_market_tool, market_tools
 from src.mcp.servers.market.xiyouzhaoci.client import XiyouZhaociAPI
 
-
 # ---------------------------------------------------------------------------
 # Fixtures
 # ---------------------------------------------------------------------------
@@ -188,8 +187,7 @@ def test_empty_asins(self, mock_api_authed):
         assert result["success"] is True
         assert mock_request.call_count == 1
         assert (
-            mock_request.call_args[1]["headers"]["request-url"]
-            == "/detail/asin/look_up/US/unknown"
+            mock_request.call_args[1]["headers"]["request-url"] == "/detail/asin/look_up/US/unknown"
         )
 
     def test_error(self, mock_api_authed):
@@ -239,6 +237,4 @@ async def test_handle_traffic_scores(self):
             data = json.loads(result[0].text)
             assert data == mock_response
 
-            mock_api_instance.get_traffic_scores.assert_called_once_with(
-                country="US", asins=asins
-            )
+            mock_api_instance.get_traffic_scores.assert_called_once_with(country="US", asins=asins)