plexus.cli.procedure.tactus_adapters.trace module

Plexus Trace Sink for Tactus trace event persistence.

class plexus.cli.procedure.tactus_adapters.trace.PlexusTraceSink(chat_recorder)

Bases: object

Persist Tactus trace records into Plexus ChatSession/ChatMessage models.

STREAM_UPDATE_MAX_INTERVAL_SECONDS = 1.2

STREAM_UPDATE_MIN_CHARS_DELTA = 48

__init__(chat_recorder)

assistant_message_texts: list[str]

async end_session(status: str = 'COMPLETED') → None

async flush() → None

mark_runtime_execute_started(value: str | None = None) → None

async record(event: Any) → str | None

session_id: str | None

async start_session(context: Dict[str, Any] | None = None) → str | None