make format

Author: tarekziade

deploy/helm/env/prod.yaml

@@ -9,7 +9,7 @@
 
 image:
   # Bump to a newer sha-<commit> (pushed by CI on merge to main) or use latest.
-  tag: sha-09bcf3a
+  tag: sha-bc6c73d
 
 replicas: 1
 
@@ -112,7 +112,7 @@ taskExecution:
     # draft on the terminal callback. false = reviews run in-process in serge.
     reviewPods: true
     # transformers toolchain + serge (docker/Dockerfile.task-runner).
-    image: ghcr.io/huggingface/serge-task-runner:sha-09bcf3a
+    image: ghcr.io/huggingface/serge-task-runner:sha-bc6c73d
     # Wall-clock cap per task (matches the old in-process worker budget).
     timeout: 3600
     # The in-pod normalizer (make style / checkers over transformers) is
@@ -122,4 +122,4 @@ taskExecution:
     nodeSelector: "scheduling.cast.ai/node-template=default-by-castai"
     egress:
       # Self-built tinyproxy (docker/Dockerfile.egress-proxy).
-      image: ghcr.io/huggingface/serge-egress:sha-09bcf3a
+      image: ghcr.io/huggingface/serge-egress:sha-bc6c73d

reviewbot/config.py

@@ -501,8 +501,7 @@ def from_env(
                 os.environ.get("TASK_K8S_NODE_SELECTOR") or ""
             ).strip()
             or None,
-            task_egress_name=(os.environ.get("TASK_EGRESS_NAME") or "").strip()
-            or None,
+            task_egress_name=(os.environ.get("TASK_EGRESS_NAME") or "").strip() or None,
             slack_bot_token=(
                 os.environ.get("SLACK_CIFEEDBACK_BOT_TOKEN")
                 or os.environ.get("CI_SLACK_BOT_TOKEN")

reviewbot/review_runner.py

@@ -35,9 +35,7 @@ def build_review_request(spec: RunnerSpec) -> ReviewRequest:
     only the fields the dataclass declares. ``inline`` (webhook follow-up
     context) is left at its default — UI reviews never carry it."""
     fields = {f.name for f in dataclasses.fields(ReviewRequest)}
-    kwargs = {
-        k: v for k, v in spec.request.items() if k in fields and k != "inline"
-    }
+    kwargs = {k: v for k, v in spec.request.items() if k in fields and k != "inline"}
     return ReviewRequest(**kwargs)
 
 

reviewbot/reviewer.py

@@ -868,7 +868,9 @@ def _run_agentic_loop(
                 truncation_retries += 1
                 _emit_final_salvage(emit, chat, truncation_retries)
                 messages.append({"role": "assistant", "content": chat.content or None})
-                messages.append({"role": "user", "content": _final_recovery_message(chat)})
+                messages.append(
+                    {"role": "user", "content": _final_recovery_message(chat)}
+                )
                 force_json_only = True
                 continue
             if validate is None:

tests/test_reviewer.py

@@ -35,7 +35,9 @@ def test_assistant_turn_records_content_and_tool_calls(self) -> None:
             content="looking at the diff",
             reasoning_chars=42,
             finish_reason="tool_calls",
-            tool_calls=[ToolCall(id="t0", name="read_file", arguments='{"path":"a.py"}')],
+            tool_calls=[
+                ToolCall(id="t0", name="read_file", arguments='{"path":"a.py"}')
+            ],
         )
         self.assertEqual(len(events), 1)
         kind, text = events[0]
@@ -75,19 +77,25 @@ def test_none_emit_is_a_noop(self) -> None:
 class FinalSalvageTests(unittest.TestCase):
     def test_empty_content_needs_salvage(self) -> None:
         # The production failure: empty completion, finish_reason=None.
-        self.assertTrue(_needs_final_salvage(ChatResult(content="", finish_reason=None)))
+        self.assertTrue(
+            _needs_final_salvage(ChatResult(content="", finish_reason=None))
+        )
         self.assertTrue(
             _needs_final_salvage(ChatResult(content="   \n", finish_reason=None))
         )
 
     def test_length_truncation_needs_salvage(self) -> None:
         self.assertTrue(
-            _needs_final_salvage(ChatResult(content='{"partial', finish_reason="length"))
+            _needs_final_salvage(
+                ChatResult(content='{"partial', finish_reason="length")
+            )
         )
 
     def test_good_answer_does_not_need_salvage(self) -> None:
         self.assertFalse(
-            _needs_final_salvage(ChatResult(content='{"ok": true}', finish_reason="stop"))
+            _needs_final_salvage(
+                ChatResult(content='{"ok": true}', finish_reason="stop")
+            )
         )
 
     def test_recovery_message_varies_by_cause(self) -> None:

tests/test_webapp_tasks.py

@@ -800,8 +800,9 @@ def test_ingest_review_reconstructs_draft(self):
         )
         from reviewbot.store import encode_draft
 
-        with patch.object(webapp, "_persist_terminal"), patch.object(
-            webapp, "_notify_task_finished"
+        with (
+            patch.object(webapp, "_persist_terminal"),
+            patch.object(webapp, "_notify_task_finished"),
         ):
             client = TestClient(webapp.app)
             r = client.post(