Ensure test runner uses test 'fluvio' for cluster setup

src/cluster/src/start/local.rs

@@ -464,8 +464,7 @@ impl LocalInstaller {
         binary
             .stdout(Stdio::from(outputs))
             .stderr(Stdio::from(errors))
-            .inherit()
-            .log()
+            .print()
             .spawn()?;
 
         Ok((LOCAL_SC_ADDRESS.to_owned(), LOCAL_SC_PORT))
@@ -638,8 +637,7 @@ impl LocalInstaller {
         info!("SPU log generated at {}", log_spu);
         cmd.stdout(Stdio::from(outputs))
             .stderr(Stdio::from(errors))
-            .inherit()
-            .log()
+            .print()
             .spawn()
             .map_err(|_| LocalInstallError::Other("SPU server failed to start".to_string()))?;
         Ok(())

src/command/src/lib.rs

@@ -80,6 +80,19 @@ pub trait CommandExt {
     ///     .spawn();
     /// ```
     fn log(&mut self) -> &mut Self;
+    /// Print a stringified version of the Command to stdout.
+    ///
+    /// # Example
+    ///
+    /// ```
+    /// use std::process::Command;
+    /// use fluvio_command::CommandExt;
+    /// let _ = Command::new("echo")
+    ///     .arg("How are you Fluvio")
+    ///     .print()
+    ///     .spawn();
+    /// ```
+    fn print(&mut self) -> &mut Self;
     /// Return a stringified version of the Command.
     ///
     /// # Example
@@ -135,6 +148,11 @@ impl CommandExt for Command {
         self
     }
 
+    fn print(&mut self) -> &mut Self {
+        println!("Command> {:?}", self.display());
+        self
+    }
+
     fn display(&self) -> String {
         format!("{:?}", self).replace("\"", "")
     }

tests/runner/src/utils/setup/environment/local.rs

@@ -29,6 +29,15 @@ impl TestEnvironmentDriver for LocalEnvDriver {
         let mut builder = LocalConfig::builder(crate::VERSION);
         builder.spu_replicas(self.option.spu()).render_checks(true);
 
+        // Make sure to use the test build of 'fluvio' for cluster components
+        let test_exe = std::env::current_exe();
+        let build_dir = test_exe
+            .ok()
+            .and_then(|it| it.parent().map(|it| it.join("fluvio")));
+        if let Some(path) = build_dir {
+            builder.launcher(path);
+        }
+
         if let Some(rust_log) = &self.option.server_log() {
             builder.rust_log(rust_log);
         }