def wait_for_hosts_to_install(self, timeout=consts.CLUSTER_INSTALLATION_TIMEOUT, fall_on_error_status=True, nodes_count: int=None):
    test_infra.utils.waiting.wait_till_all_hosts_are_in_status(client=self.api_client, cluster_id=self.id, statuses=[consts.ClusterStatus.INSTALLED], nodes_count=(nodes_count or self.nodes.nodes_count), timeout=timeout, fall_on_error_status=fall_on_error_status)
def wait_for_hosts_to_install(self, timeout=consts.CLUSTER_INSTALLATION_TIMEOUT, fall_on_error_status=True, nodes_count: int=None):
    test_infra.utils.waiting.wait_till_all_hosts_are_in_status(client=self.api_client, cluster_id=self.id, statuses=[consts.ClusterStatus.INSTALLED], nodes_count=(nodes_count or self.nodes.nodes_count), timeout=timeout, fall_on_error_status=fall_on_error_status)