replay | Kitaru

Replay planning utilities.

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

Ordering uses DAG topology derived from StepSpec.upstream_steps, matching ZenML's own Compiler._get_sorted_invocations() strategy. Timestamps are used only as a last-resort fallback for legacy runs missing topology metadata.

ReplayPlan

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

Build a replay plan for a completed/paused execution.

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.