Merge "Made processes names case sensitive"
This commit is contained in:
commit
caea4cbfc9
@ -22,7 +22,7 @@ from sahara.plugins.general import exceptions as ex
|
||||
def get_node_groups(cluster, node_process=None):
|
||||
return [ng for ng in cluster.node_groups
|
||||
if (node_process is None or
|
||||
node_process in [n.lower() for n in ng.node_processes])]
|
||||
node_process in ng.node_processes)]
|
||||
|
||||
|
||||
def get_instances_count(cluster, node_process=None):
|
||||
|
@ -140,10 +140,10 @@ class AmbariPlugin(p.ProvisioningPluginBase):
|
||||
"cluster_configs": cluster_configs})
|
||||
|
||||
def get_oozie_server(self, cluster):
|
||||
return u.get_instance(cluster, "oozie_server")
|
||||
return u.get_instance(cluster, "OOZIE_SERVER")
|
||||
|
||||
def validate_edp(self, cluster):
|
||||
oo_count = u.get_instances_count(cluster, 'oozie_server')
|
||||
oo_count = u.get_instances_count(cluster, 'OOZIE_SERVER')
|
||||
if oo_count != 1:
|
||||
raise ex.InvalidComponentCountException('oozie', '1', oo_count)
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user