Function command_worker_address

crates/hyperqueue/src/bin/hq.rs:318–336

(
    gsettings: &GlobalSettings,
    opts: WorkerAddressOpts,
)

}

async fn command_worker_address(
    gsettings: &GlobalSettings,
    opts: WorkerAddressOpts,
) -> anyhow::Result<()> {
    use hyperqueue::common::arraydef::IntArray;
    use hyperqueue::transfer::messages::IdSelector;

    let mut session = get_client_session(gsettings.server_directory()).await?;
    let selector = IdSelector::Specific(IntArray::from_id(opts.worker_id.as_num()));
    let response = get_worker_info(&mut session, selector, false).await?;

    match response.into_iter().next() {
        Some((_, Some(info))) => println!("{}", info.configuration.hostname),
        Some((id, None)) => anyhow::bail!("Worker {} not found", id),
        None => anyhow::bail!("Worker {} not found", opts.worker_id),
    }

    Ok(())
}

#[cfg(feature = "dashboard")]
/// Starts the hq dashboard