diff --git a/butcher/src/trend_setter.rs b/butcher/src/trend_setter.rs index 5636aee..0bfced1 100644 --- a/butcher/src/trend_setter.rs +++ b/butcher/src/trend_setter.rs @@ -71,7 +71,6 @@ pub fn start(mut store: Store) -> Tx { loop { let mut next_run = queue.keys().cloned().next(); - // tracing::trace!("next_run in {:?}", next_run - Instant::now()); if let Some(next_run_) = next_run { let now = Instant::now(); if next_run_ <= now { @@ -82,6 +81,14 @@ pub fn start(mut store: Store) -> Tx { // update with next in queue next_run = queue.keys().cloned().next(); + } else { + tracing::trace!("next_run in {:?}", next_run_ - now); + } + } else { + let languages = store.get_languages().await.unwrap(); + tracing::info!("queue empty, filling from {} languages", languages.len()); + for language in languages.into_iter() { + enqueue(Some(language.clone()), &mut queue, &mut buffer, HashSet::new()); } }