Skip to content

Commit 8714f92

Browse files
committed
Add warning log when a reconnection is required
1 parent b30fa30 commit 8714f92

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

crates/abq_queue/src/queue.rs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2685,7 +2685,11 @@ impl WorkScheduler {
26852685
// timing out the test run when the last test in the queue is handed out.
26862686
// However, the behavior could still be made better, in particular by
26872687
// re-enqueuing dropped tests.
2688-
opt_read_error.located(here!())?
2688+
let result = opt_read_error.located(here!());
2689+
if let Err(ref e) = result {
2690+
tracing::warn!(?e, ?run_id, ?entity, "failed to read next test request from worker connection, worker will need to reconnect");
2691+
}
2692+
result?
26892693
}
26902694
};
26912695

0 commit comments

Comments
 (0)