Struct PipelineCheckpoint 

pub struct PipelineCheckpoint {

    pub version: u32,
    pub phase: PipelinePhase,
    pub iteration: u32,
    pub total_iterations: u32,
    pub reviewer_pass: u32,
    pub total_reviewer_passes: u32,
    pub timestamp: String,
    pub developer_agent: String,
    pub reviewer_agent: String,
    pub cli_args: CliArgsSnapshot,
    pub developer_agent_config: AgentConfigSnapshot,
    pub reviewer_agent_config: AgentConfigSnapshot,
    pub rebase_state: RebaseState,
    pub config_path: Option<String>,
    pub config_checksum: Option<String>,
    pub working_dir: String,
    pub prompt_md_checksum: Option<String>,
    pub git_user_name: Option<String>,
    pub git_user_email: Option<String>,
    pub run_id: String,
    pub parent_run_id: Option<String>,
    pub resume_count: u32,
    pub actual_developer_runs: u32,
    pub actual_reviewer_runs: u32,
    pub execution_history: Option<ExecutionHistory>,
    pub file_system_state: Option<FileSystemState>,
    pub prompt_history: Option<HashMap<String, String>>,
    pub env_snapshot: Option<EnvironmentSnapshot>,
}

Enhanced pipeline checkpoint for resume functionality.

Contains comprehensive state needed to resume an interrupted pipeline exactly where it left off, including CLI arguments, agent configurations, rebase state, and file checksums for validation.

This is inspired by video game save states - capturing the complete execution context to enable seamless recovery.

Fields

version: u32

Checkpoint format version (for future compatibility)

phase: PipelinePhase

Current pipeline phase

iteration: u32

Current iteration number (for developer iterations)

total_iterations: u32

Total iterations configured

reviewer_pass: u32

Current reviewer pass number

total_reviewer_passes: u32

Total reviewer passes configured

timestamp: String

Timestamp when checkpoint was saved

developer_agent: String

Developer agent display name

reviewer_agent: String

Reviewer agent display name

cli_args: CliArgsSnapshot

CLI argument snapshot

developer_agent_config: AgentConfigSnapshot

Developer agent configuration snapshot

reviewer_agent_config: AgentConfigSnapshot

Reviewer agent configuration snapshot

rebase_state: RebaseState

Rebase state tracking

config_path: Option<String>

Path to config file used for this run (if any)

config_checksum: Option<String>

Checksum of config file (for validation on resume)

working_dir: String

Working directory when checkpoint was created

prompt_md_checksum: Option<String>

Checksum of PROMPT.md (for validation on resume)

git_user_name: Option<String>

Git user name for commits (if overridden)

git_user_email: Option<String>

Git user email for commits (if overridden)

run_id: String

Unique identifier for this run (UUID v4)

parent_run_id: Option<String>

Parent run ID if this is a resumed session

resume_count: u32

Number of times this session has been resumed

actual_developer_runs: u32

Actual number of developer iterations that completed

actual_reviewer_runs: u32

Actual number of reviewer passes that completed

execution_history: Option<ExecutionHistory>

Execution history tracking for idempotent recovery

file_system_state: Option<FileSystemState>

File system state for validation on resume

prompt_history: Option<HashMap<String, String>>

Stored prompts used during this run

env_snapshot: Option<EnvironmentSnapshot>

Environment snapshot for idempotent recovery

Implementations

impl PipelineCheckpoint

pub fn resume_context(&self) -> ResumeContext

Extract rich resume context from this checkpoint.

This method creates a ResumeContext containing all the information needed to generate informative prompts for agents when resuming.

impl PipelineCheckpoint

pub fn from_params(params: CheckpointParams<'_>) -> Self

Create a new checkpoint with comprehensive state capture.

This is the main constructor for creating checkpoints during pipeline execution. It captures all necessary state to enable exact restoration of the pipeline.

Arguments

• params - All checkpoint parameters bundled in a struct

pub fn description(&self) -> String

Get a human-readable description of the checkpoint.

Returns a string describing the current phase and progress, suitable for display to the user when resuming.

pub fn with_config(self, path: Option<PathBuf>) -> Self

Set the config path and calculate its checksum.

Trait Implementations

impl Clone for PipelineCheckpoint

fn clone(&self) -> PipelineCheckpoint

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PipelineCheckpoint

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PipelineCheckpoint

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<PipelineCheckpoint> for PipelineState

Convert v3 checkpoint to reducer PipelineState.

Migrates existing checkpoint structure to new state format, ensuring backward compatibility with saved checkpoints.

fn from(checkpoint: PipelineCheckpoint) -> Self

Converts to this type from the input type.

impl Serialize for PipelineCheckpoint

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.