fix clippy warnings

SpringQL · May 25, 2023 · 1b2bd66 · 1b2bd66
1 parent dbde4ee
commit 1b2bd66
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/springql-core/src/stream_engine/autonomous_executor/task_graph.rs b/springql-core/src/stream_engine/autonomous_executor/task_graph.rs
@@ -78,7 +78,6 @@ impl TaskGraph {
         let i = self.find_node(task_id);
         self.g
             .edges_directed(i, petgraph::EdgeDirection::Incoming)
-            .into_iter()
             .map(|e| &e.weight().queue_id)
             .cloned()
             .collect()
@@ -87,7 +86,6 @@ impl TaskGraph {
         let i = self.find_node(task_id);
         self.g
             .edges_directed(i, petgraph::EdgeDirection::Outgoing)
-            .into_iter()
             .map(|e| &e.weight().queue_id)
             .cloned()
             .collect()
@@ -101,7 +99,6 @@ impl TaskGraph {
         let i = self.find_node(task_id);
         self.g
             .edges_directed(i, petgraph::EdgeDirection::Incoming)
-            .into_iter()
             .find_map(|e| {
                 let queue_id_with_upstream = e.weight();
                 (&queue_id_with_upstream.upstream == upstream)