From c3d358faf33e57e2bdbf40827599fb9706355186 Mon Sep 17 00:00:00 2001 From: Chris Lee Date: Tue, 10 Dec 2024 11:10:47 -0700 Subject: [PATCH] [rptest] RedpandaInstaller async download rework --- tests/rptest/services/redpanda_installer.py | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/tests/rptest/services/redpanda_installer.py b/tests/rptest/services/redpanda_installer.py index e78d7ca86d91d..f31b1c407145e 100644 --- a/tests/rptest/services/redpanda_installer.py +++ b/tests/rptest/services/redpanda_installer.py @@ -701,9 +701,16 @@ def _async_download_on_node_unlocked(self, node, version): """ version_root = self.root_for_version(version) + results = [] tgz = "redpanda.tar.gz" - cmd = f"curl -vfsSL {self._version_package_url(version)} --retry 3 --retry-connrefused --retry-delay 2 --create-dir -o {version_root}/{tgz} && echo 'curl finished successfully' && gunzip -c {version_root}/{tgz} | tar -xf - -C {version_root} && echo 'tarball extraction finished successfully' && rm {version_root}/{tgz} && echo 'tarball cleanup finished successfully'" - return node.account.ssh_capture(cmd) + cmds = [ + f"curl -vfsSL {self._version_package_url(version)} --retry 3 --retry-connrefused --retry-delay 2 --create-dir -o {version_root}/{tgz}", + f"gunzip -c {version_root}/{tgz} | tar -xf - -C {version_root}", + f"rm {version_root}/{tgz}" + ] + for cmd in cmds: + results.extend(node.account.ssh_capture(cmd)) + return results def reset_current_install(self, nodes): """