trulens.core.otel.client_hooks.service¶

trulens.core.otel.client_hooks.service ¶

End-to-end hook event ingestion service.

Classes¶

HookService ¶

Normalize, sanitize, journal, assemble, and export hook events.

Functions¶

ingest ¶

ingest(
    client: str, payload: Mapping[str, Any]
) -> Tuple[str, bool]

Normalize and durably journal one hook payload without exporting.

flush ¶

flush() -> bool

Export all complete, retryable, or stale turns in the journal.

Each turn's run is created before its spans are exported, because the spans carry the run name, and its ingestion is started afterwards, which is what drives the turn's invocation to a terminal status. A turn is only marked exported once both have succeeded; otherwise it is released for retry, since spans without ingestion would leave the run in-progress forever.