audit

etl_craft.engine.audit ¶

Immutable command requests and metadata changes made through the Engine DB.

One command request, recorded once when its Engine DB becomes available.

record() -> None

Record the request itself; flow outcomes belong to run and attempt logs.

mask_arguments(arguments: Mapping[str, Any]) -> dict[str, Any]

Mask values of sensitive names, including nested arguments, before serialization.

register_engine(engine: Engine) -> None

Bind a command's first Engine DB and record its request, including rejected operations.

command_request(command: str, arguments: Mapping[str, Any]) -> Iterator[None]

Record state-changing command requests; read-only commands make no audit writes.