WIP

Cargo.toml

@@ -39,7 +39,7 @@ shlex = "1.3.0"
 ssh2 = "0.9.4"
 tar = "0.4.41"
 tempfile = "3.12.0"
-tes = { version = "0.3.0", features = ["client", "serde"] }
+tes = { version = "0.4.0", features = ["client", "serde"] }
 thiserror = "2.0.11"
 tokio = { version = "1.40.0", features = ["full", "time", "tracing"] }
 tokio-metrics = "0.3.1"

crankshaft-config/src/backend.rs

@@ -57,7 +57,8 @@ impl Config {
         self.defaults.as_ref()
     }
 
-    /// Consumes `self` returns the constituent parts of the [`Config`].
+    /// Consumes `self` returns the constituent, owned parts of the
+    /// configuration.
     pub fn into_parts(self) -> (String, Kind, usize, Option<Defaults>) {
         (self.name, self.kind, self.max_tasks, self.defaults)
     }

crankshaft-config/src/backend/tes.rs

@@ -31,4 +31,10 @@ impl Config {
     pub fn http(&self) -> &http::Config {
         &self.http
     }
+
+    /// Consumes `self` and returns the constituent, owned parts of the
+    /// configuration.
+    pub fn into_parts(self) -> (Url, http::Config) {
+        (self.url, self.http)
+    }
 }

crankshaft-engine/src/service/runner/backend/docker.rs

@@ -98,7 +98,7 @@ impl crate::Backend for Backend {
                 // (2) Upload inputs to the container.
                 //
                 // TODO(clay): these could be cached.
-                for task in task.inputs().cloned().map(|i| {
+                for task in task.inputs().map(|i| {
                     let container = container.clone();
                     tokio::spawn(async move {
                         let contents = i.fetch().await;