@cpo.event_wrapper(True, param=('self', 0))
    def provision_ambari(self, ambari_info, cluster_spec):
        self.install_rpms()
        global_config = cluster_spec.configurations['global']
        jdk_path = global_config.get('java64_home')
        if self.node_group.components in 'AMBARI_SERVER':
            self._setup_and_start_ambari_server(ambari_info.port, jdk_path)

        # all nodes must run Ambari agent
        self._setup_and_start_ambari_agent(ambari_info.host.internal_ip)
dataset/ETHPy150Open openstack/sahara/sahara/plugins/hdp/hadoopserver.py/HadoopServer.provision_ambari/swapped operands of `in`