fix clippy warnings

SpringQL · May 25, 2023 · cc2cbfa · cc2cbfa
1 parent dbde4ee
commit cc2cbfa
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 11 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)

diff --git a/springql/tests/e2e_high_level_rs.rs b/springql/tests/e2e_high_level_rs.rs
@@ -240,10 +240,7 @@ fn test_e2e_pop_from_in_memory_queue() {
 
     let pipeline = apply_ddls(&ddls, SpringConfig::default());
     test_source.start(ForeignSourceInput::new_fifo_batch(
-        (0..trade_times)
-            .into_iter()
-            .map(|_| json_oracle.clone())
-            .collect(),
+        (0..trade_times).map(|_| json_oracle.clone()).collect(),
     ));
 
     for _ in 0..trade_times {
@@ -318,10 +315,7 @@ fn test_e2e_pop_non_blocking_from_in_memory_queue() {
 
     let pipeline = apply_ddls(&ddls, SpringConfig::default());
     test_source.start(ForeignSourceInput::new_fifo_batch(
-        (0..trade_times)
-            .into_iter()
-            .map(|_| json_oracle.clone())
-            .collect(),
+        (0..trade_times).map(|_| json_oracle.clone()).collect(),
     ));
 
     for _ in 0..trade_times {