|
@@ -46,9 +46,19 @@ def config_validator():
|
|
|
Called by core check_config() view.
|
|
Called by core check_config() view.
|
|
|
"""
|
|
"""
|
|
|
from hadoop.cluster import get_all_hdfs
|
|
from hadoop.cluster import get_all_hdfs
|
|
|
|
|
+ from liboozie.oozie_api import get_oozie
|
|
|
|
|
|
|
|
res = []
|
|
res = []
|
|
|
|
|
|
|
|
|
|
+ status = 'down'
|
|
|
|
|
+ try:
|
|
|
|
|
+ status = str(get_oozie().get_oozie_status())
|
|
|
|
|
+ except:
|
|
|
|
|
+ pass
|
|
|
|
|
+ if 'NORMAL' not in status:
|
|
|
|
|
+ res.append((status, _('The Oozie server is not available')))
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
class ConfigMock:
|
|
class ConfigMock:
|
|
|
def __init__(self, value): self.value = value
|
|
def __init__(self, value): self.value = value
|
|
|
def get(self): return self.value
|
|
def get(self): return self.value
|