diff options
| author | Andrew Guschin <guschin@altlinux.org> | 2024-10-09 12:40:38 +0400 |
|---|---|---|
| committer | Andrew Guschin <guschin@altlinux.org> | 2024-10-09 12:40:38 +0400 |
| commit | 5d2b2b40b0cb0baef70934a9e6fa46fd6ab674bb (patch) | |
| tree | 6f763c9021ccf585d4886978f628eca6303bbac8 /graph-checker | |
| parent | 427205b55368108575625b8fe4d97d8825480760 (diff) | |
add timer
Diffstat (limited to 'graph-checker')
| -rw-r--r-- | graph-checker/src/main.rs | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/graph-checker/src/main.rs b/graph-checker/src/main.rs index 215b69e..2f3de7a 100644 --- a/graph-checker/src/main.rs +++ b/graph-checker/src/main.rs @@ -28,9 +28,12 @@ async fn main() -> Result<(), sqlx::Error> { let start = Instant::now(); + println!("Started"); const BATCH_SIZE: usize = 10000; + let mut count = 0; loop { let graphs = gi.take(BATCH_SIZE); + let batch = Instant::now(); let tasks: Vec<_> = graphs .map(|g| { let db = db.clone(); @@ -46,7 +49,13 @@ async fn main() -> Result<(), sqlx::Error> { }) .collect(); let part = futures::future::join_all(tasks).await; - if part.len() < BATCH_SIZE { + let sz = part.len(); + count += sz; + println!( + "Counted {count} in {}s", + batch.elapsed().as_nanos() as f64 / 1e9 + ); + if sz < BATCH_SIZE { break; } } |