astro/caveman
astro
/
caveman
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

butcher/trend_setter: fill from languages if queue is empty

This commit is contained in:
Astro 2023-01-22 23:27:27 +01:00
parent 026aa58050
commit 21b9b288f6
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
butcher/src/trend_setter.rs
View File

@ -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());
}
}