Skip to content

Commit 03c5016

Browse files
committed
bin/monitor: Convert to async main() fn
1 parent 828f52e commit 03c5016

File tree

1 file changed

+11
-6
lines changed

1 file changed

+11
-6
lines changed

src/bin/monitor.rs

Lines changed: 11 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5,19 +5,24 @@
55
//! cargo run --bin monitor
66
77
use anyhow::Result;
8+
use crates_io::tasks::spawn_blocking;
89
use crates_io::worker::jobs;
910
use crates_io::{admin::on_call, db, schema::*};
1011
use crates_io_env_vars::{var, var_parsed};
1112
use crates_io_worker::BackgroundJob;
1213
use diesel::prelude::*;
1314

14-
fn main() -> Result<()> {
15-
let conn = &mut db::oneoff_connection()?;
15+
#[tokio::main]
16+
async fn main() -> Result<()> {
17+
spawn_blocking(move || {
18+
let conn = &mut db::oneoff_connection()?;
1619

17-
check_failing_background_jobs(conn)?;
18-
check_stalled_update_downloads(conn)?;
19-
check_spam_attack(conn)?;
20-
Ok(())
20+
check_failing_background_jobs(conn)?;
21+
check_stalled_update_downloads(conn)?;
22+
check_spam_attack(conn)?;
23+
Ok(())
24+
})
25+
.await
2126
}
2227

2328
/// Check for old background jobs that are not currently running.

0 commit comments

Comments
 (0)