audit_reads

etl_craft.engine.repository.audit_reads

Read command and metadata audit records with preserved deleted-object identities.

document

document(value: Any) -> Any

Decode SQLite JSON text while preserving PostgreSQL's decoded objects.

fetch_audit_records

fetch_audit_records(conn: Connection, pipeline_id: int | None, since: datetime | None) -> tuple[list[dict[str, Any]], list[dict[str, Any]]]

Read requests and metadata changes, including tasks no longer present in CFG_TASKS.