batch_mode_batch_workflow

Function process_output_file

Source 
pub async fn process_output_file<T>(
    triple: &BatchFileTriple,
    workspace: &dyn BatchWorkspaceInterface<Item = Arc<dyn GetTargetPathForAIExpansion + Sync + Send>>,
    expected_content_type: &ExpectedContentType,
) -> Result<(), BatchOutputProcessingError>
where
    T: 'static + Send + Sync + DeserializeOwned + Named + GetTargetPathForAIExpansion,
Expand description
  • The core async function to process the output file for a given triple.
  • Now we do NDJSON line-by-line parsing, just like the older batch-mode approach.