MCPcopy Create free account
hub / github.com/It4innovations/hyperqueue / stop_worker

Method stop_worker

crates/hyperqueue/src/server/autoalloc/process.rs:2295–2307  ·  view source on GitHub ↗
(&mut self, id: WorkerId, details: LostWorkerDetails)

Source from the content-addressed store, hash-verified

2293 }
2294
2295 async fn stop_worker(&mut self, id: WorkerId, details: LostWorkerDetails) {
2296 self.handle.stop_worker(id).await;
2297 let config = self.workers.get(&id).unwrap();
2298 let info = config.get_manager_info().unwrap();
2299 assert!(
2300 handle_message(
2301 &mut self.state,
2302 &self.senders.events,
2303 AutoAllocMessage::WorkerLost(id, info, details)
2304 )
2305 .await
2306 );
2307 }
2308
2309 async fn periodic_update(&mut self) {
2310 do_periodic_update(&self.senders, &mut self.state).await;

Calls 2

get_manager_infoMethod · 0.80
getMethod · 0.45

Tested by

no test coverage detected