prodigy 0.4.4

Turn ad-hoc Claude sessions into reproducible development pipelines with parallel AI agents
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100

//! Workflow execution module
//!
//! Handles command execution with git commit verification and iteration logic.

pub mod checkpoint;
pub mod checkpoint_errors;
pub mod checkpoint_path;
#[cfg(test)]
mod checkpoint_tests;
#[cfg(test)]
mod commit_tracking_tests;
pub mod composer_integration;
pub mod composition;
#[cfg(test)]
mod conditional_tests;
pub mod effects;
pub mod error_policy;
#[cfg(test)]
mod error_policy_tests;
pub mod error_recovery;
#[cfg(test)]
mod error_recovery_tests;
mod executor;
#[cfg(test)]
mod executor_tests;
pub mod git_context;
#[cfg(test)]
mod git_context_commit_tests;
#[cfg(test)]
mod git_context_diff_tests;
#[cfg(test)]
mod git_context_test_utils;
#[cfg(test)]
mod git_context_tests;
#[cfg(test)]
mod git_context_uncommitted_tests;
mod git_utils;
pub mod normalized;
mod on_failure;
pub mod progress;
pub mod progress_config;
pub mod pure;
pub mod resume;
pub mod step_validation;
#[cfg(test)]
mod step_validation_tests;
mod traits;
pub mod validation;
pub mod variable_checkpoint;
#[cfg(test)]
mod variable_checkpoint_tests;
pub mod variables;

pub use checkpoint::ResumeOptions;
pub use checkpoint::{CheckpointManager, WorkflowCheckpoint};
pub use checkpoint_errors::{format_path, mask_secret, CheckpointError};
pub use checkpoint_path::{resolve_global_base_dir, CheckpointStorage};
pub use composer_integration::{
    is_composable_workflow, parse_composable_workflow, CompositionError,
};
pub use composition::{
    ComposableWorkflow, ComposedWorkflow, CompositionMetadata, Parameter, ParameterDefinitions,
    ParameterType, SubWorkflow, SubWorkflowExecutor, SubWorkflowResult, TemplateRegistry,
    TemplateSource, TemplateStorage, WorkflowComposer, WorkflowImport, WorkflowTemplate,
};
pub use error_policy::{
    BackoffStrategy, CircuitBreaker, CircuitBreakerConfig, CircuitState, ErrorCollectionStrategy,
    ErrorMetrics, ErrorPolicyExecutor, FailureAction, FailurePattern, ItemFailureAction,
    RetryConfig, WorkflowErrorPolicy,
};
pub use executor::{
    specialized_commands::execute_write_file_command, CaptureOutput, CommandType,
    ExtendedWorkflowConfig, HandlerStep, StepResult, WorkflowContext,
    WorkflowExecutor as WorkflowExecutorImpl, WorkflowMode, WorkflowStep,
};
pub use git_context::{GitChangeTracker, StepChanges, VariableFormat};
pub use normalized::{
    ExecutionMode, MapReduceConfig, NormalizedStep, NormalizedWorkflow, StepCommand, StepHandlers,
    WorkflowType,
};
pub use on_failure::{FailureHandlerConfig, HandlerCommand, HandlerStrategy, OnFailureConfig};
pub use progress_config::{LogLevel, ProgressConfig, ProgressDisplayMode};
pub use resume::{ResumeExecutor, ResumeResult};
pub use step_validation::{
    StepValidationConfig, StepValidationExecutor, StepValidationResult, StepValidationSpec,
};
pub use traits::{StepExecutor, WorkflowExecutor};
pub use validation::{
    GapDetail, OnIncompleteConfig, Severity, ValidationConfig, ValidationResult, ValidationStatus,
};
pub use variables::{
    CaptureFormat, CaptureStreams, CapturedValue, CommandResult, ExecutionInput, StandardVariables,
    VariableContext, VariableStore,
};

// Pure transformation module re-exports
pub use pure::{
    build_command, expand_variables, extract_variable_references, parse_output_variables,
    OutputPattern,
};