style: drop section-divider comments and surplus blank lines

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: nficano

src/arcp/_client/client.py

@@ -38,19 +38,16 @@
 
 _LOG = get_logger("arcp.client")
 
-
 def _now_iso() -> str:
     return datetime.now(UTC).isoformat().replace("+00:00", "Z")
 
-
 @dataclass(frozen=True)
 class AutoAckOptions:
     """Coalesce acks: send `session.ack` every `every_n` events, or every `interval_sec`."""
 
     every_n: int = 100
     interval_sec: float = 1.0
 
-
 class ARCPClient:
     """ARCP client: open/resume a session, submit jobs, observe events."""
 
@@ -96,7 +93,6 @@ def __init__(  # noqa: PLR0913
         self._closed = False
         self._dispatch_cache: dict[str, Callable[[Envelope], Awaitable[None]]] | None = None
 
-    # ------------------------------------------------------------ properties
     @property
     def negotiated_features(self) -> tuple[str, ...]:
         return self._negotiated
@@ -112,8 +108,6 @@ def session_id(self) -> str | None:
     def welcome(self) -> SessionWelcomePayload | None:
         return self._welcome
 
-    # --------------------------------------------------------------- connect
-
     async def connect(self, transport: Transport) -> SessionWelcomePayload:
         """Send `session.hello`, await `session.welcome`, start the read pump."""
         return await self._handshake(transport, resume=None)
@@ -155,8 +149,6 @@ async def _handshake(
             self._auto_ack_task = asyncio.create_task(self._auto_ack_loop())
         return welcome
 
-    # ------------------------------------------------------------ read pump
-
     async def _read_pump(self) -> None:
         assert self._transport is not None
         try:
@@ -194,8 +186,6 @@ def _fail_all_handles(self, exc: BaseException) -> None:
         self._pending_accepts.clear()
         self._pending.cancel_all(exc)
 
-    # ----------------------------------------------------------- auto-ack
-
     async def _auto_ack_loop(self) -> None:
         assert self.auto_ack is not None
         last_acked = 0
@@ -208,8 +198,6 @@ async def _auto_ack_loop(self) -> None:
         except asyncio.CancelledError:
             return
 
-    # ----------------------------------------------------------- ops
-
     async def submit(  # noqa: PLR0913
         self,
         *,
@@ -280,8 +268,6 @@ async def ack(self, last_processed_seq: int) -> None:
     def latest_event_seq(self) -> int:
         return self._highest_seq
 
-    # ------------------------------------------------------------ shutdown
-
     async def close(self, *, reason: str = "client.close") -> None:
         from .ops import close_session
 
@@ -290,5 +276,4 @@ async def close(self, *, reason: str = "client.close") -> None:
     async def aclose(self) -> None:
         await self.close()
 
-
 __all__ = ("ARCPClient", "AutoAckOptions")

src/arcp/_messages/execution.py

@@ -26,12 +26,9 @@
     validate_result_chunk_body,
 )
 
-# ---------- agent reference grammar (§7.5) ---------------------------------
-
 _AGENT_NAME_RE = re.compile(r"^[a-zA-Z][a-zA-Z0-9._-]*$")
 _AGENT_VERSION_RE = re.compile(r"^[a-zA-Z0-9][a-zA-Z0-9._-]*$")
 
-
 def parse_agent_ref(ref: str) -> tuple[str, str | None]:
     """Parse `name` or `name@version`; raise `ValueError` on malformed input."""
     if "@" in ref:
@@ -43,17 +40,12 @@ def parse_agent_ref(ref: str) -> tuple[str, str | None]:
         raise ValueError(f"invalid agent name: {ref!r}")
     return ref, None
 
-
 def format_agent_ref(name: str, version: str | None) -> str:
     """Inverse of `parse_agent_ref`."""
     return f"{name}@{version}" if version else name
 
-
-# ---------- budget grammar (§9.6) ------------------------------------------
-
 _BUDGET_AMOUNT_RE = re.compile(r"^([A-Za-z][A-Za-z0-9]{0,9}):([0-9]+(?:\.[0-9]+)?)$")
 
-
 def parse_budget_amount(amount: str) -> tuple[str, Decimal]:
     """Parse `currency:decimal`; raise `ValueError` on malformed input."""
     m = _BUDGET_AMOUNT_RE.match(amount)
@@ -68,17 +60,12 @@ def parse_budget_amount(amount: str) -> tuple[str, Decimal]:
         raise ValueError("budget amount must be non-negative")
     return currency, value
 
-
 def format_budget_amount(currency: str, value: Decimal) -> str:
     return f"{currency}:{value}"
 
-
-# ---------- lease (§9) ------------------------------------------------------
-
 Lease = dict[str, list[str]]
 """A lease maps capability namespace to a list of glob patterns."""
 
-
 def _ensure_utc_iso8601(value: str) -> datetime:
     """Parse a strict UTC ISO 8601 timestamp (`Z` or `+00:00` only)."""
     if not isinstance(value, str):
@@ -92,7 +79,6 @@ def _ensure_utc_iso8601(value: str) -> datetime:
         raise ValueError(f"expires_at must be UTC: {value!r}")
     return dt
 
-
 class LeaseConstraints(BaseModel):
     """Optional lease constraints (v1.1 §9.5)."""
 
@@ -107,10 +93,6 @@ def _check_expires_at(cls, v: str | None) -> str | None:
         _ensure_utc_iso8601(v)
         return v
 
-
-# ---------- job verbs (§7) -------------------------------------------------
-
-
 class JobSubmitPayload(BaseModel):
     model_config = ConfigDict(extra="allow")
     agent: str
@@ -128,7 +110,6 @@ def _check_agent(cls, v: str) -> str:
         parse_agent_ref(v)
         return v
 
-
 class JobAcceptedPayload(BaseModel):
     model_config = ConfigDict(extra="allow")
     job_id: str
@@ -141,13 +122,11 @@ class JobAcceptedPayload(BaseModel):
     delegate_id: str | None = None
     trace_id: str | None = None
 
-
 class JobCancelPayload(BaseModel):
     model_config = ConfigDict(extra="allow")
     reason: str
     code: str | None = None
 
-
 class JobEventPayload(BaseModel):
     model_config = ConfigDict(extra="allow")
     kind: str
@@ -161,7 +140,6 @@ def _check_kind(cls, v: str) -> str:
             return v
         raise ValueError(f"unknown event kind: {v!r}")
 
-
 class JobResultPayload(BaseModel):
     model_config = ConfigDict(extra="allow")
     final_status: Literal["success", "cancelled", "timed_out"]
@@ -171,7 +149,6 @@ class JobResultPayload(BaseModel):
     summary: str | None = None
     completed_at: str
 
-
 class JobErrorPayload(BaseModel):
     model_config = ConfigDict(extra="allow")
     final_status: Literal["error"] = "error"
@@ -181,17 +158,12 @@ class JobErrorPayload(BaseModel):
     completed_at: str
     details: dict[str, Any] | None = None
 
-
-# ---------- subscribe verbs (v1.1 §7.6) ------------------------------------
-
-
 class JobSubscribePayload(BaseModel):
     model_config = ConfigDict(extra="allow")
     job_id: str
     history: bool = False
     from_event_seq: int | None = Field(default=None, ge=0)
 
-
 class JobSubscribedPayload(BaseModel):
     model_config = ConfigDict(extra="allow")
     request_id: str
@@ -204,12 +176,10 @@ class JobSubscribedPayload(BaseModel):
     subscribed_from: int = 0
     replayed: int = 0
 
-
 class JobUnsubscribePayload(BaseModel):
     model_config = ConfigDict(extra="allow")
     job_id: str
 
-
 __all__ = (
     "EVENT_KINDS",
     "ArtifactRefBody",

src/arcp/_runtime/server.py

@@ -41,14 +41,11 @@
 
 _LOG = get_logger("arcp.runtime.server")
 
-
 def _now_iso() -> str:
     return datetime.now(UTC).isoformat().replace("+00:00", "Z")
 
-
 JobAuthorizationPolicy = Callable[["AuthorizationContext"], bool]
 
-
 @dataclass(frozen=True)
 class AuthorizationContext:
     """Inputs to the per-job authorization policy used by `list_jobs` and `subscribe`."""
@@ -57,20 +54,17 @@ class AuthorizationContext:
     job: Job
     operation: str  # "list" | "subscribe" | "cancel"
 
-
 def _default_authz_policy(ctx: AuthorizationContext) -> bool:
     """Same-principal default: requester must own the job (§14)."""
     return ctx.job.submitter_principal == ctx.requester_principal
 
-
 @dataclass
 class _AgentRegistration:
     name: str
     versions: dict[str, Agent] = field(default_factory=dict)
     default_version: str | None = None
     bare: Agent | None = None  # registered without a version
 
-
 class ARCPRuntime:
     """Server-side runtime: register agents, accept transports, dispatch envelopes."""
 
@@ -113,8 +107,6 @@ def __init__(  # noqa: PLR0913
         self._closed = asyncio.Event()
         self._semaphore = asyncio.Semaphore(max_concurrent_jobs)
 
-    # ------------------------------------------------------------------ agents
-
     def register_agent(self, name: str, fn: Agent) -> Self:
         reg = self._agents.setdefault(name, _AgentRegistration(name=name))
         reg.bare = fn
@@ -164,8 +156,6 @@ def _resolve_agent(self, agent_ref: str) -> tuple[Agent, str, str | None]:
             raise AgentVersionNotAvailableError(f"unknown agent version: {name}@{version}")
         return reg.versions[version], name, version
 
-    # ------------------------------------------------------------- accept loop
-
     async def accept(self, transport: Transport) -> None:
         """Drive one full session over `transport`. Returns when session ends."""
         from ._accept import run_session
@@ -198,8 +188,6 @@ def _require_feature(self, ctx: SessionContext, name: str) -> None:
         if not ctx.has_feature(name):
             raise InvalidRequestError(f"feature {name!r} not negotiated for this session")
 
-    # -------------------------------------------------------------- handlers
-
     async def _run_job(
         self,
         job: Job,
@@ -212,8 +200,6 @@ async def _run_job(
 
         await run_job(self, job, agent_fn, agent_input, max_runtime_sec=max_runtime_sec)
 
-    # ------------------------------------------------------------ shutdown
-
     async def close(self) -> None:
         self._closed.set()
         for task in list(self._job_tasks.values()):
@@ -224,7 +210,6 @@ async def close(self) -> None:
                 await task
         await self.event_log.close()
 
-
 from . import _handlers  # noqa: E402
 
 _DISPATCH_TABLE: dict[
@@ -240,7 +225,6 @@ async def close(self) -> None:
     "job.unsubscribe": ("subscribe", _handlers.handle_unsubscribe),
 }
 
-
 __all__ = (
     "ARCPRuntime",
     "AuthorizationContext",