clippy

Author: sbernauer

CHANGELOG.md

@@ -22,12 +22,14 @@ All notable changes to this project will be documented in this file.
 ### Fixed
 
 - Set connection and response timeout for Redis connections ([#85]).
+- Only remove queries from the persistence in case they don't send a `nextUri` and are in state `FINISHED` ([#98]).
 
 [#68]: https://github.com/stackabletech/trino-lb/pull/68
 [#85]: https://github.com/stackabletech/trino-lb/pull/85
 [#86]: https://github.com/stackabletech/trino-lb/pull/86
 [#91]: https://github.com/stackabletech/trino-lb/pull/91
 [#95]: https://github.com/stackabletech/trino-lb/pull/95
+[#98]: https://github.com/stackabletech/trino-lb/pull/98
 
 ## [0.5.0] - 2025-03-14
 

trino-lb/src/http_server/v1/statement.rs

@@ -458,8 +458,7 @@ async fn handle_query_running_on_trino(
     // Just to be safe the query needs to be completed and not contain any nextUri for the client
     // to call to, before being considered done. We don't expect any future calls to done queries,
     // so we can (hopefully) safely remove them from the persistence.
-    if trino_query_api_response.is_query_finished() && !trino_query_api_response.next_uri.is_some()
-    {
+    if trino_query_api_response.is_query_finished() && trino_query_api_response.next_uri.is_none() {
         info!(%query_id, "Query completed, removing it from the persistence");
 
         tokio::try_join!(