Skip to content

Commit

Permalink
what
Browse files Browse the repository at this point in the history
  • Loading branch information
untitaker committed May 15, 2024
1 parent fa3526d commit 2ff5f54
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion rust-arroyo/src/processing/strategies/reduce.rs
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,10 @@ impl<T: Send + Sync, TResult: Send + Sync> ProcessingStrategy<T> for Reduce<T, T

loop {
if deadline.map_or(false, |d| d.has_elapsed()) {
tracing::warn!("Timeout {:?} reached while waiting for tasks to finish", timeout);
tracing::warn!(
"Timeout {:?} reached while waiting for tasks to finish",
timeout
);
break;
}

Expand Down

0 comments on commit 2ff5f54

Please sign in to comment.