mixle.experimental.typed_runtime.staleness moduleΒΆ

Typed stale-proposal admission, correction, and shrinkage policy.

class CorrectionResult(source_proposal_id, source_payload_hash, run_id, model_id, node_id, target_model_version, target_dependency_versions, semantics, method, evidence_id, payload, payload_hash='')[source]

Bases: object

Identity-bound payload recomputed or approximated for target versions.

Parameters:

  • source_proposal_id (str)

  • source_payload_hash (str)

  • run_id (str)

  • model_id (str)

  • node_id (str)

  • target_model_version (int)

  • target_dependency_versions (tuple[tuple[str, int], ...])

  • semantics (CorrectionSemantics)

  • method (str)

  • evidence_id (str)

  • payload (Any)

  • payload_hash (str)

property fingerprint: str

Bind the exact correction payload, target state, method, and evidence.

class CorrectionSemantics(*values)[source]

Bases: StrEnum

Whether a corrected payload is exact at the target state or approximate.

class StalenessAction(*values)[source]

Bases: StrEnum

Coordinator action for a locally computed proposal.

class StalenessPolicy(max_model_lag=0, max_node_lag=0, shrink_decay=0.5)[source]

Bases: object

Hard lag limits and conservative stale-delta decay.

Parameters:

  • max_model_lag (int)

  • max_node_lag (int)

  • shrink_decay (float)

class StalenessReceipt(proposal_id, action, reason, model_lag, node_lag, scale, correction_fingerprint, correction_semantics, source_payload_hash, target_model_version, target_dependency_versions)[source]

Bases: object

Measured lag, consistency contract, and admission decision.

Parameters:

  • proposal_id (str)

  • action (StalenessAction)

  • reason (str)

  • model_lag (int)

  • node_lag (int)

  • scale (float)

  • correction_fingerprint (str | None)

  • correction_semantics (CorrectionSemantics | None)

  • source_payload_hash (str)

  • target_model_version (int)

  • target_dependency_versions (tuple[tuple[str, int], ...])

property accepted: bool

Whether the proposal may proceed to versioned commit preflight.

as_dict()[source]

Return a JSON-compatible staleness receipt.

Return type:

dict[str, Any]

assess_staleness(proposal, contract, current, policy, *, correction=None)[source]

Apply exact/strict/bounded/corrected semantics before payload mutation.

Parameters:

  • proposal (ProposalPacket)

  • contract (UpdateContract)

  • current (RuntimeVersions)

  • policy (StalenessPolicy)

  • correction (CorrectionResult | None)

Return type:

StalenessReceipt

shrink_proposal(proposal, receipt, *, proposal_id, correction=None)[source]

Create an identity-bound proposal after an admitted stale transformation.

Parameters:

  • proposal (ProposalPacket)

  • receipt (StalenessReceipt)

  • proposal_id (str)

  • correction (CorrectionResult | None)

Return type:

ProposalPacket