samples: workflow_streams: fix lint failures (ruff isort + format)

CI's `poe lint` step was failing on three small things across four
files:

* `run_external_publisher.py`, `ticker_workflow.py`: ruff isort
  (`I001`) wanted the `workflow_streams.shared` imports re-sorted
  and a stray blank line removed. Apply the auto-fix.
* `run_external_publisher.py`, `run_reconnecting_subscriber.py`,
  `run_truncating_ticker.py`: ruff format wanted three line-wrapped
  function calls collapsed back to single lines. Apply the
  formatter.
* `run_truncating_ticker.py`: the formatter joined an adjacent
  pair of f-strings into an awkward `f"..." f"..."` one-liner.
  Consolidate them into a single f-string for readability — the
  resulting line is comfortably under the 88-char limit.

`poe lint` (ruff isort + ruff format --check + mypy
--all-groups --check-untyped-defs) now passes locally.

Author: jssmith

workflow_streams/run_external_publisher.py

@@ -35,7 +35,6 @@
 )
 from workflow_streams.workflows.hub_workflow import HubWorkflow
 
-
 HEADLINES = [
     "rates held",
     "merger announced",
@@ -85,9 +84,7 @@ async def publish_news() -> None:
 
     async def consume_news() -> None:
         consumer = WorkflowStreamClient.create(client, workflow_id)
-        async for item in consumer.subscribe(
-            [TOPIC_NEWS], result_type=NewsEvent
-        ):
+        async for item in consumer.subscribe([TOPIC_NEWS], result_type=NewsEvent):
             if item.data.headline == DONE_HEADLINE:
                 return
             print(f"[subscriber] offset={item.offset}: {item.data.headline}")

workflow_streams/run_reconnecting_subscriber.py

@@ -109,9 +109,7 @@ async def poller() -> None:
                 emit(state, "·")
                 last_emit = now
             try:
-                await asyncio.wait_for(
-                    stop.wait(), timeout=POLL_INTERVAL_SECONDS
-                )
+                await asyncio.wait_for(stop.wait(), timeout=POLL_INTERVAL_SECONDS)
             except asyncio.TimeoutError:
                 pass
 
@@ -120,9 +118,7 @@ async def poller() -> None:
         # ---- Phase 1: connect, read a couple of events, "disconnect".
         emit(state, "[phase 1] connecting")
         seen = 0
-        async for item in stream.subscribe(
-            [TOPIC_STATUS], result_type=StageEvent
-        ):
+        async for item in stream.subscribe([TOPIC_STATUS], result_type=StageEvent):
             # Remember *one past* the offset just consumed: on resume we
             # want the next unseen event, not the one we already showed.
             state.processed = item.offset + 1

workflow_streams/run_truncating_ticker.py

@@ -110,8 +110,7 @@ async def slow_subscriber() -> None:
             if last_offset >= 0 and item.offset > last_offset + 1:
                 gap = item.offset - last_offset - 1
                 emit_slow(
-                    f"↪ jumped offset={last_offset} → {item.offset} "
-                    f"({gap} dropped)"
+                    f"↪ jumped offset={last_offset} → {item.offset} ({gap} dropped)"
                 )
             emit_slow(f"offset={item.offset:>3}  n={item.data.n}")
             last_offset = item.offset

workflow_streams/workflows/ticker_workflow.py

@@ -7,8 +7,8 @@
 
 from workflow_streams.shared import (
     TOPIC_TICK,
-    TickEvent,
     TickerInput,
+    TickEvent,
 )