primus.cli.procedure.tactus_adapters.trace module

Primus Trace Sink for Tactus trace event persistence.

class primus.cli.procedure.tactus_adapters.trace.PrimusTraceSink(chat_recorder)

Bases: object

Persist Tactus trace records into Primus ChatSession/ChatMessage models.

STREAM_UPDATE_MAX_INTERVAL_SECONDS = 0.25

STREAM_UPDATE_MIN_CHARS_DELTA = 16

__init__(chat_recorder)

assistant_message_texts: list[str]

console_audit_events: list[Dict[str, Any]]

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