Workflow channel adapter with fan-out / fan-in support. Same broad shape as ``WorkflowAdapter`` — a ``TransitionGraph`` in ``knobs["graph"]``

Read the fan-out set from a tool-call argument; map via a static dict. ``from_tool_arg`` names the tool argument whose value (a list of nickn

Adapter state for a parallel-capable workflow channel. Either ``expected_next_speaker`` is set (scalar mode) or ``pending_speakers`` is non-e

File-backed ticket store that also emits an event on every create / update / status / human-flag change, so the UI sees the lifecycle live.

Subscribes to the parent stream and every child (researcher) stream. Each stream gets a short label ([lead], [r1], [r2], ...) that prefixes i

Static fan-out target. ``agent_ids`` is the set of channel agent ids that must each speak exactly once before the workflow proceeds to the ne

Imitation WebSocket that gpt-researcher writes to via send_json(). This allows us to get the streaming output from gpt-researcher as it utili

File-backed ticket store — one ``INC-NNN.json`` per ticket in ``TICKETS_DIR``. Persists across restarts.

Forwards every accepted envelope (and channel close) to the UI as a structured event. Names resolve through the shared id→name map that the or

Emit a one-line summary of each envelope as it's accepted. Holds a *reference* to a shared id→name dict so names registered later (e.g. the s

Structured response format for agents in the escalation pattern

Feedback model for logging user feedback.

Feedback model for logging user feedback.

Structured output for task triage decisions.