async fn notify_rebuild(nexus: String, job: String) {
        info!("nexus {} received notify_rebuild from job {}", nexus, job);

        if let Some(nexus) = nexus_lookup(&nexus) {
            if let Err(e) = nexus.on_rebuild_update(job).await {
                error!(
                    "Failed to complete the rebuild with error {}",
                    e.verbose()
                );
            }
        } else {
            error!("Failed to find nexus {} for rebuild job {}", nexus, job);
        }
    }
/// Rebuild updated callback when a rebuild job state updates
Rebuild updated callback when a rebuild job state updates
Rebuild updated callback when a rebuild job state updates
async fn notify_rebuild(nexus: String, job: String) {
        info!("nexus {} received notify_rebuild from job {}", nexus, job);
        if let Some(nexus) = nexus_lookup(&nexus) {
            if let Err(e) = nexus.on_rebuild_update(job).await {
                error!(
                    "Failed to complete the rebuild with error {}",
                    e.verbose()
                );
            }
        } else {
            error!("Failed to find nexus {} for rebuild job {}", nexus, job);
        }
    }
async fn notify_rebuild ( nexus : String , job : String ) { info ! ( " " nexus job ) ; if let Some ( nexus ) = nexus_lookup ( & nexus ) { if let Err ( e ) = nexus . on_rebuild_update ( job ) . await { error ! ( " " e verbose ( ) ) ; } } else { error ! ( " " nexus job ) ; } }
Rebuild updated callback when a rebuild job state updates
Rebuild updated callback when a rebuild job state updates
nexus
String
job
String
nexus
String
job
String