Method dispatch_worker_evt

components/scheduler/src/guild_handler.rs:623–657

(
        &mut self,
        t: String,
        data: serde_json::Value,
        ack: PendingAckType,
        source: EventSource,
        ts: DateTime<Utc>,
    )

    }

    async fn dispatch_worker_evt(
        &mut self,
        t: String,
        data: serde_json::Value,
        ack: PendingAckType,
        source: EventSource,
        ts: DateTime<Utc>,
    ) {
        if self.scripts.is_empty() {
            return;
        }

        let mut ack = ack;
        loop {
            self.ensure_session().await;

            let session = self.session.as_mut().expect("ensure_session claims a worker");
            match session.dispatch(t.clone(), data.clone(), ack, source, ts) {
                Ok(()) => {
                    crate::dispatch_metrics::record_stage(
                        "worker_sent",
                        crate::dispatch_metrics::event_source_label(source),
                        ts,
                    );
                    return;
                }
                Err(returned_ack) => {
                    ack = returned_ack;
                    error!("worker died while trying to dispatch event, retrying in a second");
                    self.discard_broken_session().await;
                    tokio::time::sleep(Duration::from_secs(1)).await;
                }
            }
        }
    }

    #[instrument(skip(self), fields(guild_id = self.guild_id.get()))]
    pub(crate) async fn shutdown(&mut self) {