Skip to content

Commit 177dd7c

Browse files
committed
Fix formatting and clippy regressions
1 parent ea5f187 commit 177dd7c

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

src/paper_bench/harness.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2542,7 +2542,7 @@ fn run_sustained_system(
25422542
if win_end <= horizon_end_ms {
25432543
all_live_rows.push(rows.clone());
25442544
}
2545-
let start_join = Instant::now();
2545+
let start_join = Instant::now();
25462546
let joined = join_live_with_baseline(&[rows], &materialized_baseline_rows);
25472547
let join_duration = start_join.elapsed().as_secs_f64() * 1000.0;
25482548
if first_hybrid_result_at == 0 {

src/paper_bench/query_defined_baseline.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,10 +19,10 @@ use std::sync::{
1919
};
2020
use std::{
2121
collections::HashMap,
22+
convert::TryFrom,
2223
fs::File,
2324
io::Write,
2425
path::{Path, PathBuf},
25-
convert::TryFrom,
2626
sync::Arc,
2727
thread,
2828
time::{Duration, Instant, SystemTime, UNIX_EPOCH},
@@ -1447,7 +1447,7 @@ fn collect_live_results(
14471447
first_event_started: Instant,
14481448
expected_results: usize,
14491449
) -> Result<Vec<TimedBinding>, Box<dyn std::error::Error>> {
1450-
let deadline = Instant::now() + Duration::from_secs(10 * 60);
1450+
let deadline = Instant::now() + Duration::from_secs_f64(600.0);
14511451
let mut timed_results = Vec::new();
14521452
let mut last_progress = Instant::now();
14531453

0 commit comments

Comments
 (0)