src/main.rs

@@ -27,7 +27,7 @@ async fn rocket() -> _ {
         .await
         .unwrap();
 
-    scheduled::schedule(&db);
+    scheduled::schedule(&db).await;
 
     let rocket = rocket::build().manage(db);
 

src/scheduled/mod.rs

@@ -6,19 +6,18 @@ use job_scheduler_ng::{Job, JobScheduler};
 use rocket::tokio::{self, task};
 use sqlx::SqlitePool;
 
-pub fn schedule(db: &SqlitePool) {
+pub async fn schedule(db: &SqlitePool) {
     let db = db.clone();
 
-    tokio::task::spawn(async {
+    waterlevel::update(&db).await.unwrap();
-        waterlevel::update(&db).await.unwrap();
 
+    tokio::task::spawn(async {
         let mut sched = JobScheduler::new();
 
         // Every hour
         sched.add(Job::new("0 0 * * * * *".parse().unwrap(), move || {
             let db_clone = db.clone();
-            // Use block_in_place to run async code in the synchronous function; TODO: Make it
+            // Use block_in_place to run async code in the synchronous function
-            // nicer one's rust (stable) support async closures
             task::block_in_place(|| {
                 tokio::runtime::Handle::current().block_on(async {
                     waterlevel::update(&db_clone).await.unwrap();