internal/

Package blame attributes current DAG elements to the snapshot that introduced their persisted topology descriptor.

Package contract derives the cross-job contract graph from authoritative job, trigger, and lineage sources.

Package dag computes topology metrics for job DAGs.

Package dagrender renders DAG visualizations in ASCII.

Package dispatch implements the Phase 2 run-owner push-dispatch machinery.

Package eventmatch provides the shared event-pattern matcher and JSONPath extraction used by both the event-trigger router (internal/trigger/event) and freshness arrival bindings (internal/freshness).

Package freshness holds the data-freshness scheduling substrate: the declared dataset registry (this file) and — in later streams — the dataset state store and the leader-gated evaluator.

Package imagecheck verifies container image availability locally.

Package incident implements the Phase-0 incident substrate for agent-in-the-loop remediation: a deterministic failure classifier, a leader-gated dedupe subscriber, the incident store and status machine, a free-text log scrubber, and a durable-timer supervisor.

Package jobdef provides job definition utilities including collection and import of YAML manifests.

Package localrun executes job DAGs locally without a running server.

Package outputdiff compares recorded and reproduced task output maps.

Package receipt builds and verifies content-addressed, git-committable reproducibility receipts for a job run.

Package reproduce reconstructs and executes historical task descriptors for the caesium reproduce CLI.