mixle.experimental.typed_runtime.hierarchical module

Hierarchical island-proposal admission, merge, and transactional commit.

class HierarchicalProposalCoordinator(coordinator, *, default_staleness_policy=None, node_staleness_policies=None, payload_mergers=None, correction_provider=None)

Bases: object

Turn local-island proposals into one canonical outer transaction.

Parameters:

• coordinator (TransactionalCoordinator)

• default_staleness_policy (StalenessPolicy | None)

• node_staleness_policies (Mapping[str, StalenessPolicy] | None)

• payload_mergers (Mapping[str, PayloadMerger] | None)

• correction_provider (CorrectionProvider | None)

submit(round_id, proposals)

Admit, transform, merge, and commit one set of island proposals.

Parameters:

• round_id (str)

• proposals (Sequence[ProposalPacket])

Return type:

HierarchicalRoundReceipt

class HierarchicalRoundReceipt(round_id, input_proposal_ids, staleness, admitted_proposal_ids, merged_proposals, rejected, commit)

Bases: object

Admission, merge, rejection, and commit result for one outer round.

Parameters:

• round_id (str)

• input_proposal_ids (tuple[str, ...])

• staleness (tuple[StalenessReceipt, ...])

• admitted_proposal_ids (tuple[str, ...])

• merged_proposals (dict[str, tuple[str, ...]])

• rejected (dict[str, str])

• commit (CommitReceipt | None)

as_dict()

Return a JSON-compatible hierarchical receipt.

Return type:

dict[str, Any]