Enum PipelineEvent 

pub enum PipelineEvent {
    PipelineStarted,
    PipelineResumed {
        from_checkpoint: bool,
    },
    PipelineCompleted,
    PipelineAborted {
        reason: String,
    },
    PlanningPhaseStarted,
    PlanningPhaseCompleted,
    DevelopmentPhaseStarted,
    DevelopmentIterationStarted {
        iteration: u32,
    },
    PlanGenerationStarted {
        iteration: u32,
    },
    PlanGenerationCompleted {
        iteration: u32,
        valid: bool,
    },
    DevelopmentIterationCompleted {
        iteration: u32,
        output_valid: bool,
    },
    ContextCleaned,
    DevelopmentPhaseCompleted,
    ReviewPhaseStarted,
    ReviewPassStarted {
        pass: u32,
    },
    ReviewCompleted {
        pass: u32,
        issues_found: bool,
    },
    FixAttemptStarted {
        pass: u32,
    },
    FixAttemptCompleted {
        pass: u32,
        changes_made: bool,
    },
    ReviewPhaseCompleted {
        early_exit: bool,
    },
    AgentInvocationStarted {
        role: AgentRole,
        agent: String,
        model: Option<String>,
    },
    AgentInvocationSucceeded {
        role: AgentRole,
        agent: String,
    },
    AgentInvocationFailed {
        role: AgentRole,
        agent: String,
        exit_code: i32,
        error_kind: AgentErrorKind,
        retriable: bool,
    },
    AgentFallbackTriggered {
        role: AgentRole,
        from_agent: String,
        to_agent: String,
    },
    AgentModelFallbackTriggered {
        role: AgentRole,
        agent: String,
        from_model: String,
        to_model: String,
    },
    AgentRetryCycleStarted {
        role: AgentRole,
        cycle: u32,
    },
    AgentChainExhausted {
        role: AgentRole,
    },
    AgentChainInitialized {
        role: AgentRole,
        agents: Vec<String>,
    },
    AgentRateLimitFallback {
        role: AgentRole,
        agent: String,
        prompt_context: Option<String>,
    },
    RebaseStarted {
        phase: RebasePhase,
        target_branch: String,
    },
    RebaseConflictDetected {
        files: Vec<PathBuf>,
    },
    RebaseConflictResolved {
        files: Vec<PathBuf>,
    },
    RebaseSucceeded {
        phase: RebasePhase,
        new_head: String,
    },
    RebaseFailed {
        phase: RebasePhase,
        reason: String,
    },
    RebaseAborted {
        phase: RebasePhase,
        restored_to: String,
    },
    RebaseSkipped {
        phase: RebasePhase,
        reason: String,
    },
    CommitGenerationStarted,
    CommitMessageGenerated {
        message: String,
        attempt: u32,
    },
    CommitMessageValidationFailed {
        reason: String,
        attempt: u32,
    },
    CommitCreated {
        hash: String,
        message: String,
    },
    CommitGenerationFailed {
        reason: String,
    },
    CommitSkipped {
        reason: String,
    },
    CheckpointSaved {
        trigger: CheckpointTrigger,
    },
    FinalizingStarted,
    PromptPermissionsRestored,
    DevelopmentIterationContinuationTriggered {
        iteration: u32,
        status: DevelopmentStatus,
        summary: String,
        files_changed: Option<Vec<String>>,
        next_steps: Option<String>,
    },
    DevelopmentIterationContinuationSucceeded {
        iteration: u32,
        total_continuation_attempts: u32,
    },
}

Pipeline events representing all state transitions.

Each event captures an observable transition in pipeline execution. The reducer handles these events to compute new state.

Variants

PipelineStarted

PipelineResumed

Fields

from_checkpoint: bool

PipelineCompleted

PipelineAborted

Fields

reason: String

PlanningPhaseStarted

PlanningPhaseCompleted

DevelopmentPhaseStarted

DevelopmentIterationStarted

Fields

iteration: u32

PlanGenerationStarted

Fields

iteration: u32

PlanGenerationCompleted

Fields

iteration: u32

valid: bool

DevelopmentIterationCompleted

Fields

iteration: u32

output_valid: bool

ContextCleaned

DevelopmentPhaseCompleted

ReviewPhaseStarted

ReviewPassStarted

Fields

pass: u32

ReviewCompleted

Fields

pass: u32

issues_found: bool

FixAttemptStarted

Fields

pass: u32

FixAttemptCompleted

Fields

pass: u32

changes_made: bool

ReviewPhaseCompleted

Fields

early_exit: bool

AgentInvocationStarted

Fields

role: AgentRole

agent: String

model: Option<String>

AgentInvocationSucceeded

Fields

role: AgentRole

agent: String

AgentInvocationFailed

Fields

role: AgentRole

agent: String

exit_code: i32

error_kind: AgentErrorKind

retriable: bool

AgentFallbackTriggered

Fields

role: AgentRole

from_agent: String

to_agent: String

AgentModelFallbackTriggered

Fields

role: AgentRole

agent: String

from_model: String

to_model: String

AgentRetryCycleStarted

Fields

role: AgentRole

cycle: u32

AgentChainExhausted

Fields

role: AgentRole

AgentChainInitialized

Fields

role: AgentRole

agents: Vec<String>

AgentRateLimitFallback

Agent hit rate limit (429) - should fallback to next agent immediately.

Unlike other retriable errors (Network, Timeout), rate limits indicate the current provider is temporarily exhausted. Rather than waiting and retrying the same agent, we immediately switch to the next agent in the chain to continue work without delay.

Fields

role: AgentRole

agent: String

prompt_context: Option<String>

The prompt that was being executed when rate limit was hit. This allows the next agent to continue the same work.

RebaseStarted

Fields

phase: RebasePhase

target_branch: String

RebaseConflictDetected

Fields

files: Vec<PathBuf>

RebaseConflictResolved

Fields

files: Vec<PathBuf>

RebaseSucceeded

Fields

phase: RebasePhase

new_head: String

RebaseFailed

Fields

phase: RebasePhase

reason: String

RebaseAborted

Fields

phase: RebasePhase

restored_to: String

RebaseSkipped

Fields

phase: RebasePhase

reason: String

CommitGenerationStarted

CommitMessageGenerated

Fields

message: String

attempt: u32

CommitMessageValidationFailed

Fields

reason: String

attempt: u32

CommitCreated

Fields

hash: String

message: String

CommitGenerationFailed

Fields

reason: String

CommitSkipped

Fields

reason: String

CheckpointSaved

Fields

trigger: CheckpointTrigger

FinalizingStarted

Finalization phase started.

PromptPermissionsRestored

PROMPT.md write permissions have been restored.

This event is emitted after the RestorePromptPermissions effect successfully restores write permissions on PROMPT.md.

DevelopmentIterationContinuationTriggered

Development iteration needs continuation due to partial/failed status.

Emitted only when development output is valid (output_valid == true) and status is not “completed” (i.e., “partial” or “failed”). Invalid XML/XSD failures are handled separately and must not consume the continuation budget.

Fields

iteration: u32

Current iteration number.

status: DevelopmentStatus

Status from the agent (“partial” or “failed”).

summary: String

Summary of what was accomplished.

files_changed: Option<Vec<String>>

Files changed in this attempt.

next_steps: Option<String>

Agent’s recommended next steps.

DevelopmentIterationContinuationSucceeded

Development iteration continuation succeeded.

Emitted when a continuation attempt completes with status “completed”. This resets the continuation state and allows the iteration to complete.

Fields

iteration: u32

Current iteration number.

total_continuation_attempts: u32

Number of continuation attempts it took.

Trait Implementations

impl Clone for PipelineEvent

fn clone(&self) -> PipelineEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PipelineEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PipelineEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.