Minor fix

foxford · Oct 8, 2020 · 7a47280 · 7a47280
1 parent 554bbc8
commit 7a47280
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/backend/janus/client.rs b/src/backend/janus/client.rs
@@ -64,7 +64,7 @@ impl Client {
                 state = state
                     .into_iter()
                     .filter(|(corr_data, info)| {
-                        if info.start_timestamp + info.timeout > Utc::now() {
+                        if info.start_timestamp + info.timeout < Utc::now() {
                             let msg =
                                 format!("Janus request timed out ({}): {:?}", corr_data, info);