Method process_worker_lost

crates/hyperqueue/src/server/state.rs:198–223

(
        &mut self,
        senders: &Senders,
        worker_id: WorkerId,
        running_tasks: &[TaskId],
        reason: LostWorkerReason,
    )

    }

    pub fn process_worker_lost(
        &mut self,
        senders: &Senders,
        worker_id: WorkerId,
        running_tasks: &[TaskId],
        reason: LostWorkerReason,
    ) {
        log::debug!("Worker lost id={worker_id}");
        for tako_id in running_tasks {
            let job = self.get_job_mut(tako_id.job_id()).unwrap();
            job.set_waiting_state(tako_id.job_task_id());
        }

        let worker = self.workers.get_mut(&worker_id).unwrap();
        worker.set_offline_state(reason);

        senders.autoalloc.on_worker_lost(
            worker_id,
            &worker.configuration,
            LostWorkerDetails {
                reason,
                lifetime: (Utc::now() - worker.started_at()).to_std().unwrap(),
            },
        );
        senders.events.on_worker_lost(worker_id, reason);
    }

    pub(crate) fn restore_state(&mut self, restorer: &StateRestorer) {
        self.job_id_counter = restorer.job_id_counter()