def wait_until_hosts_are_disconnected(self, nodes_count: int=None):
    statuses = [consts.NodesStatus.DISCONNECTED]
    test_infra.utils.waiting.wait_till_all_hosts_are_in_status(client=self.api_client, cluster_id=self.id, nodes_count=(nodes_count or self.nodes.nodes_count), statuses=statuses, timeout=consts.DISCONNECTED_TIMEOUT)
def wait_until_hosts_are_disconnected(self, nodes_count: int=None):
    statuses = [consts.NodesStatus.DISCONNECTED]
    test_infra.utils.waiting.wait_till_all_hosts_are_in_status(client=self.api_client, cluster_id=self.id, nodes_count=(nodes_count or self.nodes.nodes_count), statuses=statuses, timeout=consts.DISCONNECTED_TIMEOUT)