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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117

use super::command::WorkflowCommand;
use super::mapreduce::MergeWorkflow;
use crate::cook::environment::{EnvProfile, SecretValue};
use serde::{Deserialize, Deserializer, Serialize};
use std::collections::HashMap;
use std::path::PathBuf;

/// Configuration for workflow execution
///
/// Contains a list of commands to execute in sequence for a workflow
#[derive(Debug, Clone, Serialize)]
pub struct WorkflowConfig {
    /// Workflow name (optional, defaults to "default")
    #[serde(skip_serializing_if = "Option::is_none")]
    pub name: Option<String>,

    /// Commands to execute in order
    pub commands: Vec<WorkflowCommand>,

    /// Global environment variables for all commands
    #[serde(skip_serializing_if = "Option::is_none")]
    pub env: Option<HashMap<String, String>>,

    /// Secret environment variables (masked in logs)
    #[serde(skip_serializing_if = "Option::is_none")]
    pub secrets: Option<HashMap<String, SecretValue>>,

    /// Environment files to load (.env format)
    #[serde(skip_serializing_if = "Option::is_none")]
    pub env_files: Option<Vec<PathBuf>>,

    /// Environment profiles for different contexts
    #[serde(skip_serializing_if = "Option::is_none")]
    pub profiles: Option<HashMap<String, EnvProfile>>,

    /// Optional custom merge workflow for worktree integration
    #[serde(skip_serializing_if = "Option::is_none")]
    pub merge: Option<MergeWorkflow>,
}

impl<'de> Deserialize<'de> for WorkflowConfig {
    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
    where
        D: Deserializer<'de>,
    {
        #[derive(Deserialize)]
        #[serde(untagged)]
        #[allow(clippy::large_enum_variant)]
        enum WorkflowConfigHelper {
            // New format: direct array of commands
            Commands(Vec<WorkflowCommand>),
            // Full format: object with commands and environment fields
            Full {
                #[serde(default)]
                name: Option<String>,
                commands: Vec<WorkflowCommand>,
                #[serde(default)]
                env: Option<HashMap<String, String>>,
                #[serde(default)]
                secrets: Option<HashMap<String, SecretValue>>,
                #[serde(default)]
                env_files: Option<Vec<PathBuf>>,
                #[serde(default)]
                profiles: Option<HashMap<String, EnvProfile>>,
                #[serde(default)]
                merge: Option<MergeWorkflow>,
            },
            // Old format: object with commands field only
            WithCommandsField {
                #[serde(default)]
                name: Option<String>,
                commands: Vec<WorkflowCommand>,
            },
        }

        let helper = WorkflowConfigHelper::deserialize(deserializer)?;
        match helper {
            WorkflowConfigHelper::Commands(cmds) => Ok(WorkflowConfig {
                name: None,
                commands: cmds,
                env: None,
                secrets: None,
                env_files: None,
                profiles: None,
                merge: None,
            }),
            WorkflowConfigHelper::Full {
                name,
                commands,
                env,
                secrets,
                env_files,
                profiles,
                merge,
            } => Ok(WorkflowConfig {
                name,
                commands,
                env,
                secrets,
                env_files,
                profiles,
                merge,
            }),
            WorkflowConfigHelper::WithCommandsField { name, commands } => Ok(WorkflowConfig {
                name,
                commands,
                env: None,
                secrets: None,
                env_files: None,
                profiles: None,
                merge: None,
            }),
        }
    }
}

// Remove default implementation - workflows must now be explicitly defined