From 97e19858e72ea4fb840e48e9d49672aeace8ffc8 Mon Sep 17 00:00:00 2001
From: CleverThis <hal9000@cleverthis.com>
Date: Wed, 22 Apr 2026 21:53:33 +0000
Subject: [PATCH] style(acms): apply ruff format to ACMS core pipeline
 components

Applied ruff format to fix formatting issues in acms_core_pipeline.py and acms_core_pipeline_components_steps.py that caused CI lint job failure. Changes are purely cosmetic (collapsing unnecessary multi-line expressions into single lines).

ISSUES CLOSED: #10015
---
 .../acms_core_pipeline_components_steps.py    | 32 +++++--------------
 .../services/acms_core_pipeline.py            |  4 +--
 2 files changed, 9 insertions(+), 27 deletions(-)

diff --git a/features/steps/acms_core_pipeline_components_steps.py b/features/steps/acms_core_pipeline_components_steps.py
index 90c60cf48..b57dd3f50 100644
--- a/features/steps/acms_core_pipeline_components_steps.py
+++ b/features/steps/acms_core_pipeline_components_steps.py
@@ -163,9 +163,7 @@ def step_all_positive_confidence(context: Context) -> None:
     result_names = {s.name for s, _ in context.selector_result}
     for strategy in context.core_strategies:
         if strategy.can_handle({}) > 0.0:
-            assert strategy.name in result_names, (
-                f"Expected {strategy.name} in results"
-            )
+            assert strategy.name in result_names, f"Expected {strategy.name} in results"
 
 
 @then("the core strategies should be sorted by confidence descending")
@@ -289,9 +287,7 @@ def step_given_three_varying_candidates(context: Context) -> None:
 @when("I allocate budget {budget:d} with SpecBudgetAllocator")
 def step_allocate_budget(context: Context, budget: int) -> None:
     allocator = SpecBudgetAllocator()
-    context.allocation_result = allocator.allocate(
-        context.budget_candidates, budget
-    )
+    context.allocation_result = allocator.allocate(context.budget_candidates, budget)
 
 
 @when(
@@ -302,9 +298,7 @@ def step_allocate_budget_with_min(
     context: Context, budget: int, min_budget: int
 ) -> None:
     allocator = SpecBudgetAllocator(min_useful_budget=min_budget)
-    context.allocation_result = allocator.allocate(
-        context.budget_candidates, budget
-    )
+    context.allocation_result = allocator.allocate(context.budget_candidates, budget)
 
 
 # ---------------------------------------------------------------------------
@@ -367,9 +361,7 @@ def step_given_empty_core_fragments(context: Context) -> None:
 
 @given("a core pipeline fragment with relevance {rel:g}")
 def step_given_core_fragment_relevance(context: Context, rel: float) -> None:
-    context.core_fragments = [
-        _make_core_fragment(relevance_score=rel)
-    ]
+    context.core_fragments = [_make_core_fragment(relevance_score=rel)]
 
 
 @given("a core pipeline fragment with relevance {rel:g} and priority {pri:g}")
@@ -462,9 +454,7 @@ def step_given_custom_scorer_weights(
 
 
 @given('a core pipeline fragment with metadata priority "{priority}"')
-def step_given_fragment_with_priority_metadata(
-    context: Context, priority: str
-) -> None:
+def step_given_fragment_with_priority_metadata(context: Context, priority: str) -> None:
     context.core_fragments = [
         _make_core_fragment(
             relevance_score=0.5,
@@ -475,9 +465,7 @@ def step_given_fragment_with_priority_metadata(
 
 @given("a core pipeline fragment with no priority metadata")
 def step_given_fragment_no_priority(context: Context) -> None:
-    context.core_fragments = [
-        _make_core_fragment(relevance_score=0.5)
-    ]
+    context.core_fragments = [_make_core_fragment(relevance_score=0.5)]
 
 
 # ---------------------------------------------------------------------------
@@ -634,9 +622,7 @@ def step_given_core_fragments_with_priorities(context: Context) -> None:
     context.core_fragments = frags
 
 
-@given(
-    "a core pipeline budget with max_tokens {max_t:d} and reserved_tokens {res_t:d}"
-)
+@given("a core pipeline budget with max_tokens {max_t:d} and reserved_tokens {res_t:d}")
 def step_given_core_budget(context: Context, max_t: int, res_t: int) -> None:
     context.core_budget = ContextBudget(max_tokens=max_t, reserved_tokens=res_t)
 
@@ -744,9 +730,7 @@ def step_first_ordered_node(context: Context, expected: str) -> None:
 @then('fragments from "{prefix}" should be adjacent')
 def step_fragments_adjacent(context: Context, prefix: str) -> None:
     matching_indices = [
-        i
-        for i, f in enumerate(context.core_ordered)
-        if f.uko_node.startswith(prefix)
+        i for i, f in enumerate(context.core_ordered) if f.uko_node.startswith(prefix)
     ]
     if len(matching_indices) <= 1:
         return
diff --git a/src/cleveragents/application/services/acms_core_pipeline.py b/src/cleveragents/application/services/acms_core_pipeline.py
index d5c271d62..f3b2581b5 100644
--- a/src/cleveragents/application/services/acms_core_pipeline.py
+++ b/src/cleveragents/application/services/acms_core_pipeline.py
@@ -463,9 +463,7 @@ class ConstrainedKnapsackPacker:
 
         available_tokens = budget.available_tokens
 
-        eligible = [
-            f for f in fragments if f.token_count >= self._min_fragment_tokens
-        ]
+        eligible = [f for f in fragments if f.token_count >= self._min_fragment_tokens]
 
         if max_file is not None:
             eligible = [