Function print_job_output

crates/hyperqueue/src/client/output/cli.rs:1378–1407

(
    job_detail: JobDetail,
    output_stream: OutputStream,
    task_header: bool,
    task_paths: TaskToPathsMap,
)

}

pub fn print_job_output(
    job_detail: JobDetail,
    output_stream: OutputStream,
    task_header: bool,
    task_paths: TaskToPathsMap,
) -> anyhow::Result<()> {
    let read_stream = |task_id: JobTaskId, output_stream: &OutputStream| {
        let (_, stdout_path, stderr_path) = get_task_paths(&task_paths, task_id);
        let (opt_path, stream_name) = match output_stream {
            OutputStream::Stdout => (stdout_path, "stdout"),
            OutputStream::Stderr => (stderr_path, "stderr"),
        };

        if task_header {
            println!("# Job {}, task {}", job_detail.info.id, task_id);
        }

        if let Some(path) = opt_path {
            output_file(Path::new(path));
        } else {
            log::warn!("Task {task_id} has no `{stream_name}` stream associated with it");
        }
    };

    for (task_id, _task) in &job_detail.tasks {
        read_stream(*task_id, &output_stream);
    }

    Ok(())
}

fn output_file(path: &Path) {
    let stdout = std::io::stdout();