Function output_job_task_info

crates/hyperqueue/src/client/task.rs:112–153

(
    gsettings: &GlobalSettings,
    session: &mut ClientSession,
    job_id_selector: SingleIdSelector,
    task_id_selector: TaskIdSelector,
    verbosity: Verbosity,
)

}

pub async fn output_job_task_info(
    gsettings: &GlobalSettings,
    session: &mut ClientSession,
    job_id_selector: SingleIdSelector,
    task_id_selector: TaskIdSelector,
    verbosity: Verbosity,
) -> anyhow::Result<()> {
    let message = FromClientMessage::JobDetail(JobDetailRequest {
        job_id_selector: match job_id_selector {
            SingleIdSelector::Specific(id) => IdSelector::Specific(IntArray::from_id(id)),
            SingleIdSelector::Last => IdSelector::LastN(1),
        },
        task_selector: Some(TaskSelector {
            id_selector: task_id_selector,
            status_selector: TaskStatusSelector::All,
        }),
    });
    let response =
        rpc_call!(session.connection(), message, ToClientMessage::JobDetailResponse(r) => r)
            .await?;

    let (job_id, opt_job) = response.details.first().unwrap();
    match opt_job {
        None => log::error!("Cannot find job {job_id}"),
        Some(job) => {
            let worker_map = get_worker_map(session).await?;
            gsettings.printer().print_task_info(
                (*job_id, job.clone()),
                &job.tasks,
                &worker_map,
                &response.server_uid,
                verbosity,
            );

            for task_id in &job.tasks_not_found {
                log::warn!("Task {task_id} not found");
            }
        }
    }

    Ok(())
}

pub async fn output_job_task_ids(
    gsettings: &GlobalSettings,