batch_mode_process_response/
process_batch_output_and_errors.rs

1// ---------------- [ File: src/process_batch_output_and_errors.rs ]
2crate::ix!();
3
4pub async fn process_batch_output_and_errors(
5    workspace:              &dyn BatchWorkspaceInterface, 
6    batch_execution_result: &BatchExecutionResult,
7    expected_content_type:  &ExpectedContentType,
8
9) -> Result<(),BatchProcessingError> {
10
11    // Process the outputs
12    if let Some(output_data) = &batch_execution_result.outputs() {
13        info!("processing batch output data of len {}", output_data.len());
14        process_output_data(&output_data,workspace,expected_content_type).await?;
15    }
16
17    // Process the errors
18    if let Some(error_data) = &batch_execution_result.errors() {
19        info!("processing batch error data of len {}", error_data.len());
20        process_error_data(&error_data).await?;
21    }
22
23    Ok(())
24}