clippy

ballista/rust/scheduler/src/api/mod.rs

@@ -90,14 +90,9 @@ pub fn get_routes<T: AsLogicalPlan + Clone, U: 'static + AsExecutionPlan>(
         .and_then(handlers::get_state);
 
     let route_job_summary = warp::path!("jobs" / String)
-        .and(with_data_server(scheduler_server.clone()))
+        .and(with_data_server(scheduler_server))
         .and_then(|job_id, data_server| handlers::get_job_summary(data_server, job_id));
 
-    // let route_graph = warp::path("jobs" / job_id / "graph" )
-    //     .and(with_data_server(scheduler_server.clone()))
-    //     .map(|x, job_id| handlers::get_execution_graph(x, job_id).await);
-    // .and(with_data_server(scheduler_server))
-    // .and_then();
     let routes = route_state.or(route_job_summary);
     routes.boxed()
 }

ballista/rust/scheduler/src/state/task_manager.rs

@@ -153,7 +153,7 @@ impl<T: 'static + AsLogicalPlan, U: 'static + AsExecutionPlan> TaskManager<T, U>
         if let Some(graph) = self.get_active_execution_graph(job_id).await {
             Ok(Some(Arc::new(graph.read().await.clone())))
         } else if let Ok(graph) = self.get_execution_graph(job_id).await {
-            Ok(Some(Arc::new(graph.clone())))
+            Ok(Some(Arc::new(graph)))
         } else {
             // if the job failed then we return no graph for now
             Ok(None)