def wait_for_operators_to_finish(self, timeout=consts.CLUSTER_INSTALLATION_TIMEOUT, fall_on_error_status=True):
    operators = self.get_operators()
    if fall_on_error_status:
        statuses = [consts.OperatorStatus.AVAILABLE]
    else:
        statuses = [consts.OperatorStatus.AVAILABLE, consts.OperatorStatus.FAILED]
    operators_utils.wait_till_all_operators_are_in_status(client=self.api_client, cluster_id=self.id, operators_count=len(operators_utils.filter_operators_by_type(operators, OperatorType.BUILTIN)), operator_types=[OperatorType.BUILTIN], statuses=statuses, timeout=timeout, fall_on_error_status=False)
    operators_utils.wait_till_all_operators_are_in_status(client=self.api_client, cluster_id=self.id, operators_count=len(operators_utils.filter_operators_by_type(operators, OperatorType.OLM)), operator_types=[OperatorType.OLM], statuses=[consts.OperatorStatus.AVAILABLE, consts.OperatorStatus.FAILED], timeout=timeout, fall_on_error_status=fall_on_error_status)
def wait_for_operators_to_finish(self, timeout=consts.CLUSTER_INSTALLATION_TIMEOUT, fall_on_error_status=True):
    operators = self.get_operators()
    if fall_on_error_status:
        statuses = [consts.OperatorStatus.AVAILABLE]
    else:
        statuses = [consts.OperatorStatus.AVAILABLE, consts.OperatorStatus.FAILED]
    operators_utils.wait_till_all_operators_are_in_status(client=self.api_client, cluster_id=self.id, operators_count=len(operators_utils.filter_operators_by_type(operators, OperatorType.BUILTIN)), operator_types=[OperatorType.BUILTIN], statuses=statuses, timeout=timeout, fall_on_error_status=False)
    operators_utils.wait_till_all_operators_are_in_status(client=self.api_client, cluster_id=self.id, operators_count=len(operators_utils.filter_operators_by_type(operators, OperatorType.OLM)), operator_types=[OperatorType.OLM], statuses=[consts.OperatorStatus.AVAILABLE, consts.OperatorStatus.FAILED], timeout=timeout, fall_on_error_status=fall_on_error_status)