EliChin/frostfs-testlib
1
0
Fork 0
forked from TrueCloudLab/frostfs-testlib
Code Issues Pull requests Projects Releases Packages Wiki Activity

[#189] Add setup step to check binaries versions

Browse source 
Signed-off-by: Liza <e.chichindaeva@yadro.com>
This commit is contained in:
Elizaveta Chichindaeva 2024-03-04 17:01:24 +03:00
parent 0e247c2ff2
commit f2bded64e4
1 changed files with 7 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/frostfs_testlib/utils/version_utils.py
View file

@ -1,6 +1,7 @@
import logging import logging
import re import re
from frostfs_testlib import reporter
from frostfs_testlib.cli import FrostfsAdm, FrostfsCli from frostfs_testlib.cli import FrostfsAdm, FrostfsCli
from frostfs_testlib.hosting import Host, Hosting from frostfs_testlib.hosting import Host, Hosting
from frostfs_testlib.resources.cli import FROSTFS_ADM_EXEC, FROSTFS_AUTHMATE_EXEC, FROSTFS_CLI_EXEC, NEOGO_EXECUTABLE from frostfs_testlib.resources.cli import FROSTFS_ADM_EXEC, FROSTFS_AUTHMATE_EXEC, FROSTFS_CLI_EXEC, NEOGO_EXECUTABLE
@ -10,6 +11,7 @@ from frostfs_testlib.testing.parallel import parallel
logger = logging.getLogger("NeoLogger") logger = logging.getLogger("NeoLogger")
@reporter.step("Get local binaries versions")
def get_local_binaries_versions(shell: Shell) -> dict[str, str]: def get_local_binaries_versions(shell: Shell) -> dict[str, str]:
versions = {} versions = {}
@ -29,6 +31,7 @@ def get_local_binaries_versions(shell: Shell) -> dict[str, str]:
out = shell.exec("aws --version").stdout out = shell.exec("aws --version").stdout
out_lines = out.split("\n") out_lines = out.split("\n")
versions["AWS"] = out_lines[0] if out_lines else "Unknown" versions["AWS"] = out_lines[0] if out_lines else "Unknown"
logger.info(f"Local binaries version: {out_lines[0]}")
return versions return versions
@ -66,6 +69,7 @@ def parallel_binary_verions(host: Host) -> dict[str, str]:
return versions_by_host return versions_by_host
@reporter.step("Get remote binaries versions")
def get_remote_binaries_versions(hosting: Hosting) -> dict[str, str]: def get_remote_binaries_versions(hosting: Hosting) -> dict[str, str]:
versions_by_host = {} versions_by_host = {}
future_binary_verions = parallel(parallel_binary_verions, parallel_items=hosting.hosts) future_binary_verions = parallel(parallel_binary_verions, parallel_items=hosting.hosts)
@ -94,6 +98,9 @@ def get_remote_binaries_versions(hosting: Hosting) -> dict[str, str]:
versions[name] = {"version": version, "check": binary["check"]} versions[name] = {"version": version, "check": binary["check"]}
previous_host = host previous_host = host
logger.info(
"Remote binaries versions:\n" + "\n".join([f"{key} ver: {value['version']}" for key, value in versions.items()])
)
if exception: if exception:
for i in exception: for i in exception:
for host in versions_by_host.keys(): for host in versions_by_host.keys():