mixle.experimental.typed_runtime.proposal module

Immutable update proposals, conflict analysis, and exact payload merging.

class ProposalBatch(batch_id, proposals)[source]

Bases: object

Proposals intended to commit as one versioned transaction.

Parameters:

  • batch_id (str)

  • proposals (tuple[ProposalPacket, ...])

as_dict()[source]

Return a JSON-compatible batch receipt.

Return type:

dict[str, Any]

class ProposalConflict(left_proposal, right_proposal, reason)[source]

Bases: object

A pair of proposals that cannot be committed concurrently.

Parameters:

  • left_proposal (str)

  • right_proposal (str)

  • reason (str)

class ProposalPacket(proposal_id, run_id, model_id, node_id, shard_id, base_model_version, dependency_versions, update_kind, objective_kind, payload, writes=frozenset({ArtifactKind.PARAMETERS}), observations=0.0, tokens=0, responsibility_mass=0.0, local_objective_before=None, local_objective_after=None, global_objective_before=None, global_objective_after=None, predicted_gain=None, measured_gain=None, gain_standard_error=None, optimizer_steps=0, effective_batch_size=0.0, wall_time_seconds=0.0, compute_units=0.0, communication_bytes=0, precision=None, overflow_count=0, underflow_count=0, data_fingerprint=None, data_contribution_ids=(), ordering_fingerprint=None, rng_fingerprint=None, invalidates=(), rollback_reference=None, surrogate_disclosed=False, staleness_semantics=None, correction_fingerprint=None, merge_error_bound=None, payload_hash='')[source]

Bases: object

One worker’s complete, immutable update proposal receipt.

Parameters:

  • proposal_id (str)

  • run_id (str)

  • model_id (str)

  • node_id (str)

  • shard_id (str)

  • base_model_version (int)

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

  • update_kind (UpdateKind)

  • objective_kind (ObjectiveKind)

  • payload (Any)

  • writes (frozenset[ArtifactKind])

  • observations (float)

  • tokens (int)

  • responsibility_mass (float)

  • local_objective_before (float | None)

  • local_objective_after (float | None)

  • global_objective_before (float | None)

  • global_objective_after (float | None)

  • predicted_gain (float | None)

  • measured_gain (float | None)

  • gain_standard_error (float | None)

  • optimizer_steps (int)

  • effective_batch_size (float)

  • wall_time_seconds (float)

  • compute_units (float)

  • communication_bytes (int)

  • precision (str | None)

  • overflow_count (int)

  • underflow_count (int)

  • data_fingerprint (str | None)

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

  • ordering_fingerprint (str | None)

  • rng_fingerprint (str | None)

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

  • rollback_reference (str | None)

  • surrogate_disclosed (bool)

  • staleness_semantics (str | None)

  • correction_fingerprint (str | None)

  • merge_error_bound (float | None)

  • payload_hash (str)

property dependency_version_map: dict[str, int]

Return dependency versions as a fresh mapping.

as_dict()[source]

Return metadata and payload fingerprint, never the runtime payload.

Return type:

dict[str, Any]

merge_same_node_proposals(proposals, *, merged_proposal_id, merge_law, payload_merger=None)[source]

Merge shard proposals for one node under an explicitly declared law.

Parameters:
Return type:

ProposalPacket

payload_fingerprint(value)[source]

Return a deterministic SHA-256 fingerprint without pickle or repr.

Parameters:

value (Any)

Return type:

str

proposal_conflicts(graph, batch)[source]

Return same-state and dependency-order conflicts in deterministic order.

Parameters:

  • graph (UpdateGraph)

  • batch (ProposalBatch)

Return type:

tuple[ProposalConflict, …]