chore: fmt

Author: peasee

ballista/scheduler/src/state/aqe/mod.rs

@@ -919,7 +919,9 @@ impl ExecutionGraph for AdaptiveExecutionGraph {
 
     /// Return all currently running tasks along with the executor ID on which they are assigned
     fn running_tasks(&self) -> Vec<RunningTaskInfo> {
-        self.stages.values().flat_map(|stage| {
+        self.stages
+            .values()
+            .flat_map(|stage| {
                 if let ExecutionStage::Running(stage) = stage {
                     stage
                         .running_tasks()

ballista/scheduler/src/state/execution_graph.rs

@@ -1319,7 +1319,9 @@ impl ExecutionGraph for StaticExecutionGraph {
 
     /// Return all currently running tasks along with the executor ID on which they are assigned
     fn running_tasks(&self) -> Vec<RunningTaskInfo> {
-        self.stages.values().flat_map(|stage| {
+        self.stages
+            .values()
+            .flat_map(|stage| {
                 if let ExecutionStage::Running(stage) = stage {
                     stage
                         .running_tasks()

ballista/scheduler/src/state/executor_manager.rs

@@ -438,7 +438,9 @@ impl ExecutorManager {
             get_time_before(self.config.executor_termination_grace_period);
 
         self.cluster_state
-            .executor_heartbeats().values().filter_map(|heartbeat| {
+            .executor_heartbeats()
+            .values()
+            .filter_map(|heartbeat| {
                 let terminating = matches!(
                     heartbeat
                         .status