fixup don't hang

This commit is contained in:
Mike Dilger 2022-12-30 10:07:52 +13:00
parent 9e34cd7393
commit 2c9801b9f1

View File

@ -473,7 +473,8 @@ impl Overlord {
"process_incoming_events" => {
let _ = tokio::spawn(async move {
for (event, url) in GLOBALS.incoming_events.write().await.drain(..) {
let _ = crate::process::process_new_event(&event, true, Some(url)).await;
let _ =
crate::process::process_new_event(&event, true, Some(url)).await;
}
});
}