style: fix pycodestyle E127/E128/E302/E306 in sin_delegate

Author: Delqhi

src/sin_delegate/budget_governor.py

@@ -42,11 +42,11 @@ class BudgetGovernor:
     min_grant: float = 60.0
 
     _pool: float = field(init=False, default=0.0)
-    _allocs: dict[str, Allocation] = field(init=False,
-                                          default_factory=dict)
+    _allocs: dict[str, Allocation] = field(
+        init=False, default_factory=dict)
     _deadline: float = field(init=False, default=0.0)
-    _lock: asyncio.Lock = field(init=False,
-                                default_factory=asyncio.Lock)
+    _lock: asyncio.Lock = field(
+        init=False, default_factory=asyncio.Lock)
 
     def __post_init__(self) -> None:
         self._deadline = time.monotonic() + self.global_seconds

src/sin_delegate/models.py

@@ -78,9 +78,10 @@ def finalize(self) -> "Task":
             "backend": self.agent.backend,
         }, sort_keys=True).encode()
         tid = hashlib.blake2b(payload, digest_size=8).hexdigest()
-        return Task(**{**{f: getattr(self, f)
-                           for f in self.__dataclass_fields__},
-                       "id": tid})
+        return Task(
+            **{**{f: getattr(self, f)
+                   for f in self.__dataclass_fields__},
+               "id": tid})
 
 
 @dataclass(frozen=True)

src/sin_delegate/multirepo.py

@@ -131,9 +131,10 @@ def multirepo_plan_from_dict(data: dict) -> MultiRepoPlan:
         # for these tasks, since title+instructions+backend are the
         # primary input and deps are resolved after finalization).
         if task.id != title_to_id[key]:
-            task = Task(**{**{f: getattr(task, f)
-                                for f in task.__dataclass_fields__},
-                            "id": title_to_id[key]})
+            task = Task(
+                **{**{f: getattr(task, f)
+                       for f in task.__dataclass_fields__},
+                   "id": title_to_id[key]})
         tasks.append(task)
         key_repo[task.id] = rname
 

src/sin_delegate/planfile.py

@@ -43,9 +43,10 @@ def plan_from_dict(data: dict, repo: str = ".") -> Plan:
         key = rt.get("key") or rt["title"]
         draft = _task_from(rt, deps=())
         if rt.get("id"):
-            draft = Task(**{**{f: getattr(draft, f)
-                                for f in draft.__dataclass_fields__},
-                            "id": rt["id"]})
+            draft = Task(
+                **{**{f: getattr(draft, f)
+                       for f in draft.__dataclass_fields__},
+                   "id": rt["id"]})
         drafts[key] = draft
 
     key_to_final_id = {k: t.id or t.finalize().id

src/sin_delegate/runner.py

@@ -77,11 +77,11 @@ async def run(self, task: Task, cwd: str,
         except asyncio.TimeoutError:
             proc.kill()
             await proc.wait()
-            return RunnerResult(False,
-                               f"[timeout after {timeout:.0f}s]", -1)
+            return RunnerResult(
+                False, f"[timeout after {timeout:.0f}s]", -1)
         text = redact(out.decode(errors="replace"))[-100_000:]
-        return RunnerResult(proc.returncode == 0, text,
-                           proc.returncode or 0)
+        return RunnerResult(
+            proc.returncode == 0, text, proc.returncode or 0)
 
 
 def _opencode_argv(task: Task) -> list[str]:

src/sin_delegate/scheduler.py

@@ -64,8 +64,9 @@ def _resume_states(self) -> dict[str, TaskState]:
         states: dict[str, TaskState] = {}
         for tid in self.tasks:
             prev = persisted.get(tid)
-            states[tid] = (TaskState.DONE if prev == TaskState.DONE
-                          else TaskState.PENDING)
+            states[tid] = (
+                TaskState.DONE if prev == TaskState.DONE
+                else TaskState.PENDING)
         return states
 
     def _circuit_open(self, states: dict[str, TaskState]) -> bool:

src/sin_delegate/worktree.py

@@ -66,7 +66,7 @@ def merge_back(self) -> str:
 
     def destroy(self, delete_branch: bool = True) -> None:
         _git(self.repo, "worktree", "remove", "--force",
-            str(self.path), check=False)
+             str(self.path), check=False)
         if delete_branch:
             _git(self.repo, "branch", "-D", self.branch, check=False)
 

tests/test_delegate.py

@@ -63,6 +63,7 @@ def test_scheduler_resume_skips_done(tmp_path):
     ledger.register_run(plan.id, plan.goal, "{}")
     ledger.emit(plan.id, "A", "state:done")
     calls = []
+
     async def executor(task):
         calls.append(task.id)
         return TaskOutcome(task.id, TaskState.DONE)

tests/test_intelligence_multirepo.py

@@ -24,6 +24,7 @@
 from sin_delegate.policy import Policy
 from sin_delegate.resolution import apply_resolutions
 
+
 # --------------------------------------------------------------- analytics
 
 def test_wilson_punishes_small_samples():
@@ -154,8 +155,8 @@ def test_resolve_requires_input_for_retry(tmp_path):
     esc = broker.raise_escalation(
         "p1", "T1", "t", EscalationKind.GATE_FAILURE, "x", {})
     assert not broker.resolve("p1", esc.id, "retry")["ok"]
-    assert broker.resolve("p1", esc.id, "retry",
-                            user_input="fix")["ok"]
+    assert broker.resolve(
+        "p1", esc.id, "retry", user_input="fix")["ok"]
 
 
 def test_resolve_is_idempotent(tmp_path):
@@ -168,8 +169,9 @@ def test_resolve_is_idempotent(tmp_path):
 
 def test_apply_resolutions_drop_yields_pending_or_skipped(tmp_path):
     ledger = Ledger(tmp_path / "l.db")
-    plan = Plan(goal="g", repo=".",
-               tasks=(Task(title="t", instructions="x", id="T1"),))
+    plan = Plan(
+        goal="g", repo=".",
+        tasks=(Task(title="t", instructions="x", id="T1"),))
     broker = EscalationBroker(ledger)
     ledger.register_run(plan.id, "g", json.dumps({
         "goal": "g", "tasks": [{"id": "T1", "title": "t"}]}))