Method shutdown

components/scheduler/src/guild_handler.rs:660–687

(&mut self)

    #[instrument(skip(self), fields(guild_id = self.guild_id.get()))]
    pub(crate) async fn shutdown(&mut self) {
        info!("shutting down guild handler");

        {
            let Some(session) = &mut self.session else {
                return;
            };

            // wait until the vm has finished its work
            if session.send_complete().is_err() {
                self.discard_broken_session().await;
                return;
            }
        }

        while let Some(session) = &mut self.session {
            let msg = session.recv().await;
            let events = session
                .handle_worker_msg(msg)
                .into_iter()
                // we asked the vm to shut down, keep the worker claimed until
                // the shutdown message arrives instead of returning it on idle
                .filter(|evt| !matches!(evt, SessionEvent::VmIdle))
                .collect();

            self.handle_session_events(events).await;
        }
    }

    async fn fetch_premium_tier(&mut self) {
        self.premium_tier = PremiumTierState::Unknown;