Await metadata calculation

catenarytransit · Mar 31, 2024 · 4375deb · 4375deb
1 parent 3a55b60
commit 4375deb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/maple/main.rs b/src/maple/main.rs
@@ -264,7 +264,7 @@ async fn run_ingest() -> Result<(), Box<dyn Error + std::marker::Send + Sync>> {
                 &dmfr_result,
                 &chateau_result,
                 Arc::clone(&arc_conn_pool),
-            );
+            ).await;
 
             // 4. Unzip folders
             println!("Unzipping all gtfs folders");
@@ -436,7 +436,7 @@ async fn run_ingest() -> Result<(), Box<dyn Error + std::marker::Send + Sync>> {
                 &dmfr_result,
                 &chateau_result,
                 Arc::clone(&arc_conn_pool),
-            );
+            ).await?;
         }
     } else {
         eprintln!("Not enough data in transitland!");