aeat.domain.calculations.registry._checker_oracle_flow module

Shared verdict-flow helpers for read-only checker oracles.

Provides the _CheckerBaseModel base, shared flow helpers, and the decode_replay_observation() convenience used by every BaseCheckerOracle subclass (GROI, NIF-IVA, and future sibling checkers).

normalize_verdict_mapping(values, *, blank_message)

Normalize identifier/verdict mappings and reject blank entries.

Return type:

dict[str, str]

Parameters:

• values (Mapping[str, str])

• blank_message (str)

normalize_expected_verdicts(expected, *, blank_message)

Normalize expected identifier/verdict mappings and reject blank entries.

Return type:

dict[str, str]

Parameters:

• expected (Mapping[str, object])

• blank_message (str)

replay_parse_operation(action)

Return the single local replay-parse RemoteOperation tuple.

Return type:

tuple[RemoteOperation, ...]

Parameters:

action (str)

decode_replay_observation(payload, *, surface_label, observation_type)

Decode replay JSON into the requested observation model.

Return type:

TypeVar(ObservationT, bound= _CheckerBaseModel)

Parameters:

• payload (bytes)

• surface_label (str)

• observation_type (type[ObservationT])

observed_verdict(values, key)

Return the observed verdict for key after identifier normalization.

Return type:

str | None

Parameters:

• values (Mapping[str, str])

• key (str)

compare_verdict_field(key, expected, *, observed)

Compare one expected verdict against one observed verdict and return a ParityFieldComparison.

Return type:

ParityFieldComparison

Parameters:

• key (str)

• expected (str)

• observed (str | None)