EventSink

ctrlrun.EventSink — class, defined at src/ctrlrun/receipt.py:410

from ctrlrun import EventSink

class EventSink(Protocol)
    def on_event(event: Event) -> None
    def on_receipt(receipt: Receipt) -> None

Somewhere a copy of every Event and Receipt goes (SPEC-v0.2 §4.1). Control calls a sink after the authoritative store write for that record has succeeded, in registration order, with the event_id the store assigned. A sink is the interface for the copies; it is not the interface for the record — the store’s own events and receipts tables are written inside the store, in its transaction, before any sink runs (§4.3). Sinks are not transactional, not ordered across processes, and not retried. A sink that must not lose records buffers and retries inside itself. And a sink never raises into the kernel: Control catches every Exception and carries on (§4.2).

Python API index.
Get started · Why.

Reference

Python API

Next

​Next

Next