style: apply ruff format

Author: nficano

src/arcp/_client/client.py

@@ -114,9 +114,7 @@ def __init__(  # noqa: PLR0913
         # The handle is created synchronously when `job.accepted` is dispatched
         # so any terminal arriving immediately after (e.g. idempotent replay)
         # can resolve it before the original `submit()` returns.
-        self._pending_accepts: dict[
-            str, asyncio.Future[tuple[JobAcceptedPayload, JobHandle]]
-        ] = {}
+        self._pending_accepts: dict[str, asyncio.Future[tuple[JobAcceptedPayload, JobHandle]]] = {}
         self._closed = False
         self._dispatch_cache: dict[str, Callable[[Envelope], Awaitable[None]]] | None = None
 
@@ -159,9 +157,7 @@ async def connect(self, transport: Transport) -> SessionWelcomePayload:
         """
         return await self._handshake(transport, resume=None)
 
-    async def resume(
-        self, transport: Transport, *, resume: SessionResume
-    ) -> SessionWelcomePayload:
+    async def resume(self, transport: Transport, *, resume: SessionResume) -> SessionWelcomePayload:
         """Rejoin a previously-disconnected session.
 
         Sends `session.hello` with a `resume` block carrying the prior

src/arcp/_runtime/_handlers.py

@@ -222,9 +222,7 @@ async def _issue_credentials(
     if runtime.credential_provisioner is None or not ctx.has_feature("provisioned_credentials"):
         return ()
     if runtime.revocation_log is None:
-        raise InternalError(
-            "credential provisioner is configured but revocation_log is missing"
-        )
+        raise InternalError("credential provisioner is configured but revocation_log is missing")
     provisioner_ctx = JobCredentialContext(
         job_id=job.job_id,
         agent=job.agent,

src/arcp/_runtime/_handshake.py

@@ -88,9 +88,7 @@ async def _perform_resume(  # noqa: PLR0913
     """
     record = runtime._pop_resumable(resume.session_id)
     if record is None:
-        raise PermissionDeniedError(
-            f"no resumable session for session_id={resume.session_id!r}"
-        )
+        raise PermissionDeniedError(f"no resumable session for session_id={resume.session_id!r}")
     if not hmac.compare_digest(record.resume_token, resume.resume_token):
         raise PermissionDeniedError("resume_token does not match")
     if record.principal != identity.principal:
@@ -121,9 +119,7 @@ async def _perform_resume(  # noqa: PLR0913
     ctx.stamp_and_enqueue(_build_welcome_envelope(runtime, ctx, welcome_caps, negotiated))
     # Replay everything strictly greater than `resume.last_event_seq` so the
     # peer rejoins exactly where it left off.
-    async for env_wire in runtime.event_log.read_since_seq(
-        ctx.session_id, resume.last_event_seq
-    ):
+    async for env_wire in runtime.event_log.read_since_seq(ctx.session_id, resume.last_event_seq):
         ctx.stamp_and_enqueue(Envelope.from_wire(env_wire))
     return ctx
 

src/arcp/_runtime/job.py

@@ -226,9 +226,7 @@ async def metric(self, body: dict[str, Any]) -> None:
         # arithmetic does not lose precision through a float round-trip.
         raw_value = body.get("value", 0)
         try:
-            normalized = (
-                raw_value if isinstance(raw_value, Decimal) else Decimal(str(raw_value))
-            )
+            normalized = raw_value if isinstance(raw_value, Decimal) else Decimal(str(raw_value))
         except (InvalidOperation, ValueError) as exc:
             raise ValueError("metric.value must be a number or numeric string") from exc
         # Rewrite the body so downstream validation and the wire payload see a

src/arcp/_runtime/session.py

@@ -206,9 +206,7 @@ async def write_pump(
             try:
                 await event_log.append(session_id, wire)
             except Exception:
-                _LOG.exception(
-                    "event_log_append_failed", session_id=session_id, type=item.type
-                )
+                _LOG.exception("event_log_append_failed", session_id=session_id, type=item.type)
         try:
             await transport.send(wire)
         except TransportClosed:

tests/state/test_resume.py

@@ -47,9 +47,7 @@ async def test_resume_token_rotates_across_connections() -> None:
     await rt.close()
 
 
-async def _run_one_submit(
-    rt: ARCPRuntime, capabilities: Capabilities
-) -> tuple[str, str, int]:
+async def _run_one_submit(rt: ARCPRuntime, capabilities: Capabilities) -> tuple[str, str, int]:
     """Connect, submit one job, wait for result, drop transport. Return (session_id, resume_token, latest_seq)."""
     server_t, client_t = pair_memory_transports()
     accept_task = asyncio.create_task(rt.accept(server_t))