Method run

components/scheduler/src/scheduler.rs:74–100

(mut self)

    }

    pub async fn run(mut self) {
        loop {
            match self.next_action().await {
                SchedulerAction::Cmd(Some(SchedulerCommand::Shutdown)) => {
                    break;
                }
                SchedulerAction::Cmd(Some(cmd)) => self.handle_scheduler_command(cmd).await,
                // rpc server shut down, shut down scheduler aswell then
                SchedulerAction::Cmd(None) => break,

                SchedulerAction::GuildHandler(guild_id, None) => {
                    // worker finished, remove it
                    self.guilds.remove(&guild_id);

                    if self.try_unsuspend_guild(guild_id) {
                        self.check_queue_start_worker(guild_id).await;
                    }
                }
                SchedulerAction::GuildHandler(g, Some(evt)) => {
                    self.handle_guild_handler_event(g, evt)
                }
            }
        }

        self.shutdown_all();
        self.wait_all_shutdown().await;
    }

    async fn wait_all_shutdown(&mut self) {
        info!("shutdown pending guilds: {}", self.guilds.len());