plexus.console.chat_runtime module

class plexus.console.chat_runtime.ConsoleMessage(id: 'str', account_id: 'str', session_id: 'str', procedure_id: 'str', content: 'str', role: 'str', message_type: 'str', human_interaction: 'str', response_target: 'str', response_status: 'str', created_at: 'str', selected_model: 'Optional[str]' = None)

Bases: object

__init__(id: str, account_id: str, session_id: str, procedure_id: str, content: str, role: str, message_type: str, human_interaction: str, response_target: str, response_status: str, created_at: str, selected_model: str | None = None) → None

account_id: str

content: str

created_at: str

human_interaction: str

id: str

message_type: str

procedure_id: str

response_status: str

response_target: str

role: str

selected_model: str | None = None

session_id: str

plexus.console.chat_runtime.build_response_owner(target: str, *, request_id: str | None = None) → str

plexus.console.chat_runtime.claim_message(client: PlexusDashboardClient, message: ConsoleMessage, *, expected_target: str, owner: str) → bool

plexus.console.chat_runtime.fetch_assistant_chat_messages_between(client: PlexusDashboardClient, *, session_id: str, start_created_at: str, end_created_at: str, limit: int = 3) → List[str]

plexus.console.chat_runtime.fetch_chat_session(client: PlexusDashboardClient, session_id: str) → Dict[str, Any] | None

plexus.console.chat_runtime.fetch_first_assistant_chunk_timestamp(client: PlexusDashboardClient, session_id: str, *, after_iso: str | None, max_items: int = 300) → str | None

plexus.console.chat_runtime.fetch_message(client: PlexusDashboardClient, message_id: str) → ConsoleMessage | None

plexus.console.chat_runtime.fetch_recent_user_chat_turns(client: PlexusDashboardClient, session_id: str, *, max_turns: int = 3) → List[Dict[str, str]]

plexus.console.chat_runtime.fetch_session_history(client: PlexusDashboardClient, session_id: str, *, limit: int = 16) → List[Dict[str, str]]

plexus.console.chat_runtime.mark_message_completed(client: PlexusDashboardClient, message_id: str, *, created_at: str | None) → None

plexus.console.chat_runtime.mark_message_failed(client: PlexusDashboardClient, message_id: str, error: Exception, *, created_at: str | None) → None

plexus.console.chat_runtime.maybe_auto_title_session(client: PlexusDashboardClient, *, message: ConsoleMessage) → None

plexus.console.chat_runtime.normalize_response_target(value: str | None) → str

plexus.console.chat_runtime.parse_chat_message(raw: Dict[str, Any]) → ConsoleMessage | None

plexus.console.chat_runtime.process_console_message(client: PlexusDashboardClient, raw_message: Dict[str, Any], *, expected_target: str, owner: str) → bool

plexus.console.chat_runtime.process_pending_local_messages(client: PlexusDashboardClient, *, response_target: str, owner: str, limit: int = 5) → int

plexus.console.chat_runtime.run_console_chat_response(client: PlexusDashboardClient, message: ConsoleMessage, *, owner: str, latency_trace: Dict[str, Any] | None = None) → Dict[str, Any]

async plexus.console.chat_runtime.run_console_chat_response_async(client: PlexusDashboardClient, message: ConsoleMessage, *, owner: str, latency_trace: Dict[str, Any] | None = None) → Dict[str, Any]

plexus.console.chat_runtime.should_handle_message(message: ConsoleMessage, expected_target: str) → bool

plexus.console.chat_runtime.update_chat_session_title(client: PlexusDashboardClient, *, session_id: str, title: str, turn: int, trigger_message_id: str | None, existing_metadata: Dict[str, Any] | None) → None

plexus.console.chat_runtime.utc_now() → str