DICE API Documentation/com.embabel.dice.common/ExtractionRunTransitioned

ExtractionRunTransitioned

data class ExtractionRunTransitioned constructor(val run: ExtractionRun, val timestamp: Instant = Instant.now()) : DiceEvent

An extraction run ended, and this is the call that ended it.

It fires once per run, from the store, after the terminal write has landed. A coordinator retrying a terminal write it never saw the answer to gets a replay, and a replay fires nothing — so a listener counting finished runs, or kicking off work behind one, sees each run once however many times its terminal write was sent.

The run carries everything there is to know about how it ended: the tenant, the lineage, the terminal status, the finish time, the counts, and the failures in their closed vocabulary. There is no source text or provider message anywhere in it, so this event is safe to hand to a listener that logs or forwards what it receives.

EXPERIMENTAL. The shape may still change while extraction runs (DICE #67) land.

Constructors

ExtractionRunTransitioned

constructor(run: ExtractionRun, timestamp: Instant = Instant.now())

Properties

run

val run: ExtractionRun

The run in its terminal state.

timestamp

open val timestamp: Instant

When the event was created.