replay | Kitaru

Replay planning utilities.

This module translates Kitaru replay semantics (from_ + overrides) into the ZenML replay inputs consumed by Pipeline.replay(...).

ReplayPlan

funcbuild_replay_plan(*, run, from_, overrides=None, flow_inputs=None) -> ReplayPlan

Build a replay plan for a completed/paused execution.

Replay starts from the explicit from_ checkpoint. For checkpoint overrides, the direct consumers of each overridden source are added as replay roots (the source itself is not forced to re-execute).

paramrunPipelineRunResponse

Source execution to replay from.

paramfrom_str

Checkpoint selector (checkpoint name, invocation ID, or call ID).

paramoverridesMapping[str, Any] | None

= None

Optional checkpoint override map (checkpoint.* keys).

paramflow_inputsMapping[str, Any] | None

= None

Optional flow input overrides.

Returns

kitaru.replay.ReplayPlan

A resolved replay plan.