[#258] add test preupgrade #258
2 changed files with 9 additions and 1 deletions
|
@ -110,7 +110,7 @@ class FrostfsAdmMorph(CliCommand):
|
||||||
**{param: param_value for param, param_value in locals().items() if param not in ["self"]},
|
**{param: param_value for param, param_value in locals().items() if param not in ["self"]},
|
||||||
)
|
)
|
||||||
|
|
||||||
def dump_hashes(self, rpc_endpoint: str) -> CommandResult:
|
def dump_hashes(self, rpc_endpoint: str, domain: Optional[str] = None) -> CommandResult:
|
||||||
"""Dump deployed contract hashes.
|
"""Dump deployed contract hashes.
|
||||||
|
|
||||||
Args:
|
Args:
|
||||||
|
|
|
@ -531,3 +531,11 @@ class ClusterStateController:
|
||||||
except Exception as err:
|
except Exception as err:
|
||||||
logger.warning(f"Host ping fails with error {err}")
|
logger.warning(f"Host ping fails with error {err}")
|
||||||
return HostStatus.ONLINE
|
return HostStatus.ONLINE
|
||||||
|
|
||||||
|
@reporter.step("Get contract by domain - {domain_name}")
|
||||||
|
def get_domain_contracts(self, cluster_node: ClusterNode, domain_name: str):
|
||||||
|
frostfs_adm = FrostfsAdm(
|
||||||
|
shell=cluster_node.host.get_shell(),
|
||||||
|
frostfs_adm_exec_path=FROSTFS_ADM_EXEC,
|
||||||
|
)
|
||||||
|
return frostfs_adm.morph.dump_hashes(cluster_node.morph_chain.get_endpoint(), domain_name).stdout
|
||||||
|
|
Loading…
Reference in a new issue