From 880c5f385ed1b531dbef49bf657c8b559034c471 Mon Sep 17 00:00:00 2001 From: Syfaro Date: Tue, 14 Jan 2020 02:19:42 -0600 Subject: [PATCH] Fix trying to load hashes before loop finished. --- src/bin/load_hashes.rs | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/src/bin/load_hashes.rs b/src/bin/load_hashes.rs index 5663c6c..899438f 100644 --- a/src/bin/load_hashes.rs +++ b/src/bin/load_hashes.rs @@ -86,20 +86,17 @@ async fn main() { .expect("Unable to build http client"); let client = std::sync::Arc::new(client); - let mut needed_posts = load_next_posts(pool.clone()).await; - loop { println!("running loop"); + let needed_posts = load_next_posts(pool.clone()).await; + if needed_posts.is_empty() { println!("no posts, waiting a minute"); tokio::time::delay_for(std::time::Duration::from_secs(60)).await; continue; } - let db = pool.clone(); - let posts_fut = tokio::spawn(async move { load_next_posts(db).await }); - for chunk in needed_posts.chunks(8) { let futs = chunk.iter().map(|post| { let db = pool.clone(); @@ -136,7 +133,5 @@ async fn main() { futures::future::join_all(futs).await; } - - needed_posts = posts_fut.await.unwrap(); } }