@classmethod
    def _flume_validation(cls, cluster):
        a_count = cls._get_inst_count(cluster, 'FLUME_AGENT')
        dn_count = cls._get_inst_count(cluster, 'HDFS_DATANODE')

        if a_count >= 1:
            if 1 < dn_count:
                raise ex.RequiredServiceMissingException(
                    'HDFS_DATANODE', required_by='FLUME_AGENT')
dataset/ETHPy150Open openstack/sahara/sahara/plugins/cdh/v5_3_0/validation.py/ValidatorV530._flume_validation/swapped operands of `<`