rust fmt

probably-nothing-labs · Sep 6, 2024 · 9a2391d · 9a2391d
1 parent d4213c7
commit 9a2391d
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 23 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/core/src/datastream.rs b/crates/core/src/datastream.rs
@@ -137,10 +137,7 @@ impl DataStream {
         if orchestrator::SHOULD_CHECKPOINT {
             let plan = self.df.as_ref().clone().create_physical_plan().await?;
             let node_ids = extract_node_ids_and_partitions(&plan);
-            let max_buffer_size = node_ids
-                .iter()
-                .map(|x| x.1)
-                .sum::<usize>();
+            let max_buffer_size = node_ids.iter().map(|x| x.1).sum::<usize>();
             let mut orchestrator = Orchestrator::default();
             SpawnedTask::spawn_blocking(move || orchestrator.run(max_buffer_size));
         }