Method run

core/src/serve/schedule.rs:84–94

Run until `cancel` fires; one independent loop per job.

(self, sink: Arc<dyn ScheduleSink>, cancel: CancellationToken)

    /// Run until `cancel` fires; one independent loop per job.
    pub async fn run(self, sink: Arc<dyn ScheduleSink>, cancel: CancellationToken) {
        let mut handles = Vec::new();
        for job in self.jobs {
            let sink = Arc::clone(&sink);
            let cancel = cancel.clone();
            handles.push(tokio::spawn(run_job(job, sink, cancel)));
        }
        for h in handles {
            let _ = h.await;
        }
    }
}

async fn run_job(job: ScheduledJob, sink: Arc<dyn ScheduleSink>, cancel: CancellationToken) {