batch-mode-batch-triple 0.2.1

Manages batch file triples (input, output, error, metadata) in batch processing systems, including file validation, error handling, and file movement.
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

// ---------------- [ File: batch-mode-batch-triple/src/mock.rs ]
crate::ix!();

#[cfg(test)]
pub fn make_mock_batch_file_triple() -> BatchFileTriple {
    let workspace = Arc::new(MockBatchWorkspace::default());
    BatchFileTriple::new_direct(
        &BatchIndex::new(),
        None, None, None, None,
        workspace
    )
}

#[cfg(test)]
pub fn make_mock_triple_with_files(
    input_ids:  Option<Vec<&str>>,
    output_ids: Option<Vec<&str>>,
    error_ids:  Option<Vec<&str>>,
) -> BatchFileTriple {
    // Build a MockBatchWorkspace that has the requested ID lists
    let workspace = MockBatchWorkspaceBuilder::default()
        .input_ids(
            input_ids
                .unwrap_or_default()
                .into_iter()
                .map(|s| s.to_string())
                .collect(),
        )
        .output_ids(
            output_ids
                .unwrap_or_default()
                .into_iter()
                .map(|s| s.to_string())
                .collect(),
        )
        .error_ids(
            error_ids
                .unwrap_or_default()
                .into_iter()
                .map(|s| s.to_string())
                .collect(),
        )
        .build()
        .unwrap();

    BatchFileTriple::new_direct(
        &BatchIndex::new(),
        Some(PathBuf::from("test_input.json")),
        Some(PathBuf::from("test_output.json")),
        Some(PathBuf::from("test_error.json")),
        None,
        Arc::new(workspace),
    )
}

#[cfg(test)]
pub fn make_mock_triple_files(
    input_ids:  Option<Vec<&str>>,
    output_ids: Option<Vec<&str>>
) -> BatchFileTriple {
    let workspace = MockBatchWorkspaceBuilder::default()
        .input_ids(
            input_ids
                .unwrap_or_default()
                .into_iter()
                .map(|s| s.to_string())
                .collect(),
        )
        .output_ids(
            output_ids
                .unwrap_or_default()
                .into_iter()
                .map(|s| s.to_string())
                .collect(),
        )
        .build()
        .unwrap();

    BatchFileTriple::new_direct(
        &BatchIndex::new(),
        Some(PathBuf::from("in.json")),
        Some(PathBuf::from("out.json")),
        None,
        None,
        Arc::new(workspace),
    )
}