Get DB from the context if possible

Author: Kobzol

src/db.rs

@@ -235,8 +235,9 @@ pub async fn schedule_job(
     Ok(())
 }
 
-pub async fn run_scheduled_jobs(ctx: &Context, db: &DbClient) -> anyhow::Result<()> {
-    let jobs = get_jobs_to_execute(&db).await.unwrap();
+pub async fn run_scheduled_jobs(ctx: &Context) -> anyhow::Result<()> {
+    let db = &ctx.db.get().await;
+    let jobs = get_jobs_to_execute(&db).await?;
     tracing::trace!("jobs to execute: {:#?}", jobs);
 
     for job in jobs.iter() {

src/main.rs

@@ -401,13 +401,12 @@ fn spawn_job_runner(ctx: Arc<Context>) {
         loop {
             let ctx = ctx.clone();
             let res = task::spawn(async move {
-                let pool = db::ClientPool::new();
                 let mut interval =
                     time::interval(time::Duration::from_secs(JOB_PROCESSING_CADENCE_IN_SECS));
 
                 loop {
                     interval.tick().await;
-                    db::run_scheduled_jobs(&ctx, &*pool.get().await)
+                    db::run_scheduled_jobs(&ctx)
                         .await
                         .context("run database scheduled jobs")
                         .unwrap();