Function output_job_task_ids

crates/hyperqueue/src/client/task.rs:155–194

(
    gsettings: &GlobalSettings,
    session: &mut ClientSession,
    opts: JobTaskIdsOpts,
)

}

pub async fn output_job_task_ids(
    gsettings: &GlobalSettings,
    session: &mut ClientSession,
    opts: JobTaskIdsOpts,
) -> anyhow::Result<()> {
    let message = FromClientMessage::JobDetail(JobDetailRequest {
        job_id_selector: opts.selector,
        task_selector: Some(TaskSelector {
            id_selector: TaskIdSelector::All,
            status_selector: if opts.filter.is_empty() {
                TaskStatusSelector::All
            } else {
                TaskStatusSelector::Specific(opts.filter)
            },
        }),
    });
    let response =
        rpc_call!(session.connection(), message, ToClientMessage::JobDetailResponse(r) => r)
            .await?;
    let mut job_task_ids: Vec<_> = response
        .details
        .iter()
        .map(|(job_id, detail)| {
            Ok((
                *job_id,
                IntArray::from_sorted_ids(
                    detail
                        .as_ref()
                        .ok_or_else(|| HqError::GenericError("Job Id not found".to_string()))?
                        .tasks
                        .iter()
                        .map(|(task_id, _)| task_id.as_num()),
                ),
            ))
        })
        .collect::<crate::Result<Vec<(JobId, IntArray)>>>()?;
    job_task_ids.sort_unstable_by_key(|x| x.0);
    gsettings.printer().print_task_ids(job_task_ids);
    Ok(())
}

pub async fn output_job_task_explain(
    gsettings: &GlobalSettings,