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

//! Dead Letter Queue command implementation
//!
//! This module handles DLQ management for failed MapReduce items.

use crate::cli::args::DlqCommands;
use anyhow::Result;

/// Execute DLQ-related commands
pub async fn run_dlq_command(command: DlqCommands) -> Result<()> {
    match command {
        DlqCommands::List {
            job_id: _job_id,
            eligible: _eligible,
            limit: _limit,
        } => {
            println!("Listing DLQ (Dead Letter Queue) items...");
            Ok(())
        }
        DlqCommands::Inspect {
            item_id: _item_id,
            job_id: _job_id,
        } => {
            println!("Inspecting DLQ item...");
            Ok(())
        }
        DlqCommands::Analyze {
            job_id: _job_id,
            export: _export,
        } => {
            println!("Analyzing DLQ failure patterns...");
            Ok(())
        }
        DlqCommands::Export {
            output: _output,
            job_id: _job_id,
            format: _format,
        } => {
            println!("Exporting DLQ items...");
            Ok(())
        }
        DlqCommands::Purge {
            older_than_days: _older_than_days,
            job_id: _job_id,
            yes: _yes,
        } => {
            println!("Purging old DLQ items...");
            Ok(())
        }
        DlqCommands::Retry {
            workflow_id: _workflow_id,
            filter: _filter,
            max_retries: _max_retries,
            parallel: _parallel,
            force: _force,
        } => {
            println!("Retrying failed DLQ items...");
            Ok(())
        }
        DlqCommands::Stats {
            workflow_id: _workflow_id,
        } => {
            println!("Showing DLQ statistics...");
            Ok(())
        }
        DlqCommands::Clear {
            workflow_id: _workflow_id,
            yes: _yes,
        } => {
            println!("Clearing processed DLQ items...");
            Ok(())
        }
    }
}