style: ruff import-sort + format fixes across the harness package

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

Author: declan-scale

src/agentex/lib/core/harness/__init__.py

@@ -5,17 +5,17 @@
 harness tap gets streaming + tracing + turn usage uniformly.
 """
 
-from agentex.lib.core.harness.emitter import UnifiedEmitter
-from agentex.lib.core.harness.tracer import SpanTracer
 from agentex.lib.core.harness.types import (
-    CloseSpan,
-    HarnessTurn,
     OpenSpan,
+    CloseSpan,
+    TurnUsage,
     SpanSignal,
-    StreamTaskMessage,
     TurnResult,
-    TurnUsage,
+    HarnessTurn,
+    StreamTaskMessage,
 )
+from agentex.lib.core.harness.tracer import SpanTracer
+from agentex.lib.core.harness.emitter import UnifiedEmitter
 
 __all__ = [
     "UnifiedEmitter",

src/agentex/lib/core/harness/auto_send.py

@@ -4,17 +4,16 @@
 
 from typing import Any, AsyncIterator
 
+from agentex.types.text_delta import TextDelta
+from agentex.lib.core.harness.types import TurnUsage, TurnResult, StreamTaskMessage
+from agentex.lib.core.harness.tracer import SpanTracer
 from agentex.types.task_message_update import (
-    StreamTaskMessageDelta,
     StreamTaskMessageDone,
     StreamTaskMessageFull,
+    StreamTaskMessageDelta,
     StreamTaskMessageStart,
 )
-from agentex.types.text_delta import TextDelta
-
 from agentex.lib.core.harness.span_derivation import SpanDeriver
-from agentex.lib.core.harness.tracer import SpanTracer
-from agentex.lib.core.harness.types import StreamTaskMessage, TurnResult, TurnUsage
 
 
 async def auto_send(

src/agentex/lib/core/harness/emitter.py

@@ -4,9 +4,9 @@
 
 from typing import AsyncGenerator
 
-from agentex.lib.core.harness.auto_send import auto_send
+from agentex.lib.core.harness.types import TurnResult, HarnessTurn, StreamTaskMessage
 from agentex.lib.core.harness.tracer import SpanTracer
-from agentex.lib.core.harness.types import HarnessTurn, StreamTaskMessage, TurnResult
+from agentex.lib.core.harness.auto_send import auto_send
 from agentex.lib.core.harness.yield_delivery import yield_events
 
 

src/agentex/lib/core/harness/span_derivation.py

@@ -9,18 +9,17 @@
 import json
 from dataclasses import dataclass
 
+from agentex.lib.core.harness.types import OpenSpan, CloseSpan, SpanSignal, StreamTaskMessage
+from agentex.types.tool_request_delta import ToolRequestDelta
 from agentex.types.task_message_update import (
-    StreamTaskMessageDelta,
     StreamTaskMessageDone,
     StreamTaskMessageFull,
+    StreamTaskMessageDelta,
     StreamTaskMessageStart,
 )
 from agentex.types.tool_request_content import ToolRequestContent
-from agentex.types.tool_request_delta import ToolRequestDelta
 from agentex.types.tool_response_content import ToolResponseContent
 
-from agentex.lib.core.harness.types import CloseSpan, OpenSpan, SpanSignal, StreamTaskMessage
-
 
 @dataclass
 class _ToolReqMeta:

src/agentex/lib/core/harness/tracer.py

@@ -4,7 +4,7 @@
 
 from typing import Any
 
-from agentex.lib.core.harness.types import CloseSpan, OpenSpan, SpanSignal
+from agentex.lib.core.harness.types import OpenSpan, CloseSpan, SpanSignal
 
 try:
     from agentex.lib.utils.logging import make_logger

src/agentex/lib/core/harness/types.py

@@ -2,16 +2,17 @@
 
 from __future__ import annotations
 
-from dataclasses import dataclass, field
-from typing import Any, AsyncIterator, Literal, Protocol, Union, runtime_checkable
+from typing import Any, Union, Literal, Protocol, AsyncIterator, runtime_checkable
+from dataclasses import field, dataclass
+
+from pydantic import BaseModel, ConfigDict
 
 from agentex.types.task_message_update import (
-    StreamTaskMessageDelta,
     StreamTaskMessageDone,
     StreamTaskMessageFull,
+    StreamTaskMessageDelta,
     StreamTaskMessageStart,
 )
-from pydantic import BaseModel, ConfigDict
 
 # The canonical stream element. Taps yield these; delivery adapters consume them.
 StreamTaskMessage = Union[

src/agentex/lib/core/harness/yield_delivery.py

@@ -2,11 +2,11 @@
 
 from __future__ import annotations
 
-from typing import AsyncGenerator, AsyncIterator
+from typing import AsyncIterator, AsyncGenerator
 
-from agentex.lib.core.harness.span_derivation import SpanDeriver
-from agentex.lib.core.harness.tracer import SpanTracer
 from agentex.lib.core.harness.types import StreamTaskMessage
+from agentex.lib.core.harness.tracer import SpanTracer
+from agentex.lib.core.harness.span_derivation import SpanDeriver
 
 
 async def yield_events(

tests/lib/core/harness/conformance/runner.py

@@ -18,8 +18,8 @@
 
 from dataclasses import dataclass
 
-from agentex.lib.core.harness.span_derivation import SpanDeriver
 from agentex.lib.core.harness.types import SpanSignal, StreamTaskMessage
+from agentex.lib.core.harness.span_derivation import SpanDeriver
 
 
 @dataclass

tests/lib/core/harness/conformance/test_conformance.py

@@ -1,24 +1,36 @@
 import pytest
 
-from tests.lib.core.harness.conformance.runner import Fixture, derive_all, register, all_fixtures
 from agentex.types.task_message_update import (
-    StreamTaskMessageStart, StreamTaskMessageDone, StreamTaskMessageFull,
+    StreamTaskMessageDone,
+    StreamTaskMessageFull,
+    StreamTaskMessageStart,
 )
 from agentex.types.tool_request_content import ToolRequestContent
 from agentex.types.tool_response_content import ToolResponseContent
+from tests.lib.core.harness.conformance.runner import Fixture, register, derive_all, all_fixtures
 
-register(Fixture(
-    name="builtin-single-tool",
-    events=[
-        StreamTaskMessageStart(type="start", index=0,
-            content=ToolRequestContent(type="tool_request", author="agent",
-                                       tool_call_id="c", name="Bash", arguments={})),
-        StreamTaskMessageDone(type="done", index=0),
-        StreamTaskMessageFull(type="full", index=1,
-            content=ToolResponseContent(type="tool_response", author="agent",
-                                        tool_call_id="c", name="Bash", content="ok")),
-    ],
-))
+register(
+    Fixture(
+        name="builtin-single-tool",
+        events=[
+            StreamTaskMessageStart(
+                type="start",
+                index=0,
+                content=ToolRequestContent(
+                    type="tool_request", author="agent", tool_call_id="c", name="Bash", arguments={}
+                ),
+            ),
+            StreamTaskMessageDone(type="done", index=0),
+            StreamTaskMessageFull(
+                type="full",
+                index=1,
+                content=ToolResponseContent(
+                    type="tool_response", author="agent", tool_call_id="c", name="Bash", content="ok"
+                ),
+            ),
+        ],
+    )
+)
 
 
 @pytest.mark.parametrize("fixture", all_fixtures(), ids=lambda f: f.name)