style(langgraph): satisfy summarizer ruff format check

Format the ci_failure_summarizer files that were still failing the PR #272 lint workflow while keeping the earlier lint, type-check, and CodeQL fixes intact.

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: 2 people

agents/langgraph/templates/ci_failure_summarizer/src/ci_failure_summarizer/config.py

@@ -6,9 +6,7 @@
 from os import getenv
 
 QG4_WORKFLOW_FILE = "agent-deployment-test.yaml"
-CI_DASHBOARD_URL = (
-    "https://red-hat-data-services.github.io/agentic-starter-kits/"
-)
+CI_DASHBOARD_URL = "https://red-hat-data-services.github.io/agentic-starter-kits/"
 
 
 @dataclass(frozen=True)

agents/langgraph/templates/ci_failure_summarizer/src/ci_failure_summarizer/failure_evidence.py

@@ -129,7 +129,9 @@ def build_evidence_signature(
     fallback_excerpt: str | None = None,
 ) -> str | None:
     payload_parts = markers or ([fallback_excerpt] if fallback_excerpt else [])
-    normalized = [part.strip().lower() for part in payload_parts if part and part.strip()]
+    normalized = [
+        part.strip().lower() for part in payload_parts if part and part.strip()
+    ]
     if not normalized:
         return None
     return sha256("|".join(normalized).encode("utf-8")).hexdigest()[:16]
@@ -170,7 +172,9 @@ def evidence_from_metadata(metadata: dict[str, Any] | None) -> FailureEvidence |
     excerpt = str(metadata.get("evidence_excerpt") or "").strip()
     markers = tuple(
         marker
-        for marker in (str(value).strip() for value in metadata.get("evidence_markers") or [])
+        for marker in (
+            str(value).strip() for value in metadata.get("evidence_markers") or []
+        )
         if marker
     )
     signature = metadata.get("evidence_signature")
@@ -184,7 +188,9 @@ def evidence_from_metadata(metadata: dict[str, Any] | None) -> FailureEvidence |
         source=source,
         excerpt=excerpt,
         markers=markers,
-        signature=str(signature) if signature else build_evidence_signature(list(markers), fallback_excerpt=excerpt),
+        signature=str(signature)
+        if signature
+        else build_evidence_signature(list(markers), fallback_excerpt=excerpt),
         run_id=run_id,
     )
 
@@ -199,9 +205,13 @@ def merge_failure_evidence(
         return primary
     excerpt = primary.excerpt or fallback.excerpt
     markers = primary.markers or fallback.markers
-    signature = primary.signature or fallback.signature or build_evidence_signature(
-        list(markers),
-        fallback_excerpt=excerpt,
+    signature = (
+        primary.signature
+        or fallback.signature
+        or build_evidence_signature(
+            list(markers),
+            fallback_excerpt=excerpt,
+        )
     )
     return FailureEvidence(
         source=primary.source or fallback.source,

agents/langgraph/templates/ci_failure_summarizer/src/ci_failure_summarizer/github_client.py

@@ -44,9 +44,7 @@ def _classify_api_error(response: requests.Response, *, operation: str) -> str:
         detail = message or "resource not found"
         return f"GitHub {detail} while {operation}"
     if message:
-        return (
-            f"GitHub API error ({response.status_code}) while {operation}: {message}"
-        )
+        return f"GitHub API error ({response.status_code}) while {operation}: {message}"
     return f"GitHub API request failed ({response.status_code}) while {operation}"
 
 
@@ -126,9 +124,7 @@ def _request(
     ) -> requests.Response:
         url = f"{API_ROOT}{path}"
         try:
-            response = self._session.request(
-                method, url, params=params, timeout=30
-            )
+            response = self._session.request(method, url, params=params, timeout=30)
         except requests.RequestException as exc:
             raise RuntimeError(
                 f"GitHub API network error while {method} {path}: {type(exc).__name__}"
@@ -236,9 +232,7 @@ def is_failed_job(job: WorkflowJob) -> bool:
     @staticmethod
     def failed_step_name(job: WorkflowJob) -> str | None:
         failed_steps = [
-            step.name
-            for step in job.steps
-            if step.conclusion in FAILED_CONCLUSIONS
+            step.name for step in job.steps if step.conclusion in FAILED_CONCLUSIONS
         ]
         if failed_steps:
             return failed_steps[-1]

agents/langgraph/templates/ci_failure_summarizer/src/ci_failure_summarizer/summary_composer.py

@@ -25,10 +25,7 @@ def compose_summary(
     incidents: list[Incident],
 ) -> str:
     if not failures:
-        return (
-            f"No failed jobs found for workflow run #{run.id} "
-            f"({run.html_url})."
-        )
+        return f"No failed jobs found for workflow run #{run.id} ({run.html_url})."
     incident_by_fp = {incident.fingerprint: incident for incident in incidents}
     lines = [
         f"*CI Triage Summary* — {run.name}",
@@ -82,13 +79,18 @@ def _classify_failure(
     excerpt = evidence.excerpt if evidence else ""
     haystack = "\n".join(markers + ([excerpt] if excerpt else []))
     evidence_line = select_best_error_marker(markers) or (
-        _first_meaningful_line(excerpt) or "No deterministic evidence markers extracted."
+        _first_meaningful_line(excerpt)
+        or "No deterministic evidence markers extracted."
     )
     source = _source_label(failure, evidence)
 
     route_match = _ROUTE_NOT_FOUND_RE.search(haystack)
     if route_match:
-        route_name = route_match.group("route") or route_match.group("route2") or failure.job_name
+        route_name = (
+            route_match.group("route")
+            or route_match.group("route2")
+            or failure.job_name
+        )
         return {
             "cause": "The pre-deployed agent route was missing, so the integration test could not resolve the expected endpoint.",
             "evidence": f"{source}: {evidence_line}",

agents/langgraph/templates/ci_failure_summarizer/tests/integration/conftest.py

@@ -64,6 +64,7 @@ def _write_env_file(agent_dir, container_image):
             "Set them in the CI workflow or export locally."
         )
     env_path = agent_dir / ".env"
+
     def shell_assign(name: str, value: str) -> str:
         return f"{name}={shlex.quote(value)}"
 

agents/langgraph/templates/ci_failure_summarizer/tests/test_github_client.py

@@ -145,9 +145,7 @@ def test_fetch_job_logs_degrades_on_403():
     response = MagicMock()
     response.status_code = 403
     response.headers = {}
-    response.json.return_value = {
-        "message": "Must have admin rights to Repository."
-    }
+    response.json.return_value = {"message": "Must have admin rights to Repository."}
     client._request = MagicMock(return_value=response)  # type: ignore[method-assign]
 
     result = client.fetch_job_logs(222)
@@ -165,9 +163,7 @@ def test_fetch_job_logs_reports_rate_limit_on_403():
         "X-RateLimit-Remaining": "0",
         "Retry-After": "42",
     }
-    response.json.return_value = {
-        "message": "API rate limit exceeded for user"
-    }
+    response.json.return_value = {"message": "API rate limit exceeded for user"}
     client._request = MagicMock(return_value=response)  # type: ignore[method-assign]
 
     result = client.fetch_job_logs(222)
@@ -200,14 +196,14 @@ def test_fetch_job_logs_prefers_failed_step_section_over_cleanup_tail():
     response.text = "\n".join(
         [
             "2026-07-20T04:19:20.4451275Z ##[group]Run oc login \\",
-            '2026-07-20T04:19:20.4451819Z oc login --token=\"$OC_TOKEN\"',
+            '2026-07-20T04:19:20.4451819Z oc login --token="$OC_TOKEN"',
             "2026-07-20T04:19:20.4452455Z oc login --namespace=ci-testing",
             "2026-07-20T04:19:20.4535385Z env:",
             "2026-07-20T04:19:20.4535806Z   API_KEY: not_needed",
             "2026-07-20T04:19:20.4536805Z   MODEL_ID: qwen2-5-7b-instruct",
             "2026-07-20T04:19:24.5216230Z >           raise RouteNotFoundError(agent_name, stderr=result.stderr.strip())",
             "2026-07-20T04:19:24.5217171Z E           integration.utils.RouteNotFoundError: No route found for langflow-simple-tool-calling-agent",
-            '2026-07-20T04:19:24.5217971Z E           oc stderr: Error from server (NotFound): routes.route.openshift.io \"langflow-simple-tool-calling-agent\" not found',
+            '2026-07-20T04:19:24.5217971Z E           oc stderr: Error from server (NotFound): routes.route.openshift.io "langflow-simple-tool-calling-agent" not found',
             "2026-07-20T04:19:24.5225846Z tests/integration/conftest.py:33: Failed",
             "2026-07-20T04:19:24.5655062Z ##[error]Process completed with exit code 2.",
             "2026-07-20T04:19:24.5725669Z ##[group]Run actions/upload-artifact@v4",
@@ -232,7 +228,7 @@ def test_fetch_job_logs_prefers_failed_step_section_over_cleanup_tail():
 def test_select_best_error_marker_prefers_specific_route_not_found_marker():
     wrapper = "E Failed: Pre-deployed agent route not found"
     route_marker = (
-        'E oc stderr: Error from server (NotFound): routes.route.openshift.io '
+        "E oc stderr: Error from server (NotFound): routes.route.openshift.io "
         '"langflow-simple-tool-calling-agent" not found'
     )
 

agents/langgraph/templates/ci_failure_summarizer/tests/test_grouping.py

@@ -25,10 +25,7 @@
 def _load_fixture() -> tuple[WorkflowRun, list[WorkflowJob]]:
     payload = json.loads((FIXTURES / "github_failure_run.json").read_text())
     run = WorkflowRun.from_api(payload["workflow_runs"][0])
-    jobs = [
-        WorkflowJob.from_api(job)
-        for job in payload["jobs"][str(run.id)]["jobs"]
-    ]
+    jobs = [WorkflowJob.from_api(job) for job in payload["jobs"][str(run.id)]["jobs"]]
     return run, jobs
 
 
@@ -37,7 +34,10 @@ def test_extract_qg_label_from_workflow_name():
 
 
 def test_infer_failure_area_for_health_check():
-    assert infer_failure_area("test-agent (langgraph-react-agent)", "Health check") == "health-check"
+    assert (
+        infer_failure_area("test-agent (langgraph-react-agent)", "Health check")
+        == "health-check"
+    )
 
 
 def test_build_fingerprint_is_stable():

agents/langgraph/templates/ci_failure_summarizer/tests/test_incident_store.py

@@ -192,18 +192,23 @@ def fake_connection():
 
     failure = _sample_failure()
     failure = FailureRecord(
-        **{**failure.__dict__, "evidence": FailureEvidence(
-            source="github_job_log",
-            excerpt="ERROR: health check failed",
-            markers=("ERROR: health check failed",),
-            signature="sig-123",
-            run_id=123456789,
-        )}
+        **{
+            **failure.__dict__,
+            "evidence": FailureEvidence(
+                source="github_job_log",
+                excerpt="ERROR: health check failed",
+                markers=("ERROR: health check failed",),
+                signature="sig-123",
+                run_id=123456789,
+            ),
+        }
     )
 
     with patch.object(store, "_connection", fake_connection):
         store.upsert_failures([failure])
 
     execute_kwargs = mock_conn.execute.call_args.args[1]
-    assert '"evidence_excerpt": "ERROR: health check failed"' in execute_kwargs["metadata"]
+    assert (
+        '"evidence_excerpt": "ERROR: health check failed"' in execute_kwargs["metadata"]
+    )
     assert '"evidence_signature": "sig-123"' in execute_kwargs["metadata"]

agents/langgraph/templates/ci_failure_summarizer/tests/test_summary_composer.py

@@ -237,5 +237,8 @@ def test_compose_fallback_summary_renders_missing_env_var_recommendation():
     assert "`CONTAINER_IMAGE`" in summary
     assert "`CONTAINER_IMAGE_CREW`" in summary
     assert "`CONTAINER_IMAGE_LANGGRAPH`" in summary
-    assert "ERROR: Set CONTAINER_IMAGE or both CONTAINER_IMAGE_CREW and CONTAINER_IMAGE_LANGGRAPH in .env" in summary
+    assert (
+        "ERROR: Set CONTAINER_IMAGE or both CONTAINER_IMAGE_CREW and CONTAINER_IMAGE_LANGGRAPH in .env"
+        in summary
+    )
     assert 'pytest.fail(f"Deployment failed: {exc}")' not in summary