Strip HTML and truncate to _BODY_MAX_CHARS.

Full clean: drop skip keys, strip HTML from body fields, truncate.

Try to extract a JSON object from a string.

Retrieves route information using Google Maps Directions API. API documentation at https://developers.google.com/maps/documentation/directions/get

Create a timestamped output directory and initialise references.md.

Convert a JSON array file to a JSONL temp file (required by graphrag_sdk).

Wait until RemTriage routes the 'human' into the fan-out (so the operator is a valid pending speaker), obtain the operator's decision from the

Run a full incident flow on the shared hub. Fire-and-forget task.

Keep only metadata fields from a single email dict.

Every non-accused suspect must have at least one fact placing them outside the study during the window. The study's GPS starts with "40.81". D

Archives an email by removing it from the INBOX (moves to All Mail).

Authenticate with Google Drive and return credentials

Build the round-end EV_PACKET envelope. Same shape as WorkflowAdapter's, with one important addition: we enrich ``routing`` with ``to

check order return eligibility for user.

LLM config for the live commentator.

Convert a Unix timestamp in milliseconds to local time. Args: timestamp_ms (int): Timestamp in milliseconds. Returns: s

Create and configure all agents for the research-writing group chat.

LLM config for the detective agent. Default: a local OpenAI-compatible MLX server running Qwen. Switch to GeminiConfig / VertexAIConfig / etc

Fetches all emails in a thread given a thread ID. Args: gmail (Resource): Gmail API service instance. thread_id (str): The t

Generate a filename based on the research query.

Map WMO weather code to human-readable condition.

Groups emails by sender email. Args: email_list (List[Dict[str, Union[str, List[str]]]]): List of parsed email data. Returns:

Main function to demonstrate the Escalation Pattern with the Group Chat orchestration engine.

Returns an (AssistantAgent, UserProxyAgent) pair with tinyfish registered.

Build a Participant list. First entry is the INITIATOR.

REAL duplicate lookup: non-duplicate tickets for the same system + issue created within the lookback window, oldest first.

Fetches and parses email data, including subject, sender, body, and attachments.

Use a one-shot agent call to extract option_a and option_b from the topic. Falls back to generic labels if parsing fails.

Runs the agent synchronously and returns the final JSON result.

Run the context-aware routing pattern for dynamic domain-based routing

Drive one ticket through the diagnosis workflow end-to-end. ``incident`` is a ``mock_world.INCIDENTS`` entry (system / issue / sev / kickoff)