Method execute_docker_command

src/mz-debug/src/docker_dumper.rs:46–81

Execute a Docker command and return (stdout, stderr).

(
        &self,
        args: &[String],
    )

    /// Execute a Docker command and return (stdout, stderr).
    async fn execute_docker_command(
        &self,
        args: &[String],
    ) -> Result<(Vec<u8>, Vec<u8>), anyhow::Error> {
        retry::Retry::default()
            .max_duration(DOCKER_RESOURCE_DUMP_TIMEOUT)
            .retry_async(|_| {
                let args = args.to_vec();
                async move {
                    let output = tokio::process::Command::new("docker")
                        .args(&args)
                        .output()
                        .await;

                    match output {
                        Ok(output) if output.status.success() => {
                            RetryResult::Ok((output.stdout, output.stderr))
                        }
                        Ok(output) => {
                            let err_msg = format!(
                                "Docker command failed: {:#}. Retrying...",
                                String::from_utf8_lossy(&output.stderr)
                            );
                            warn!("{}", err_msg);
                            RetryResult::RetryableErr(anyhow::anyhow!(err_msg))
                        }
                        Err(err) => {
                            let err_msg = format!("Failed to execute Docker command: {:#}", err);
                            warn!("{}", err_msg);
                            RetryResult::RetryableErr(anyhow::anyhow!(err_msg))
                        }
                    }
                }
            })
            .await
    }

    async fn dump_logs(&self) -> Result<(), anyhow::Error> {
        let (stdout, stderr) = self