Add missing tests to ambari/configs.py

Add:
	*test_get_service_to_configs_map()

Change-Id: Id440a447a1029c8d592dfa048cf83565d42a6b46
This commit is contained in:
jiasen.lin 2017-03-17 10:48:48 -04:00
parent 1931533ca2
commit 55996857da
1 changed files with 37 additions and 0 deletions

View File

@ -17,6 +17,7 @@
import collections
import mock
import six
from sahara.plugins.ambari import configs
from sahara.tests.unit import base
@ -47,6 +48,42 @@ class AmbariConfigsTestCase(base.SaharaTestCase):
self.assertEqual(len(expected), len(cnt_ex))
self.assertEqual(len(actual), len(cnt_act))
def test_get_service_to_configs_map(self):
self.assertIsNone(configs.SERVICES_TO_CONFIGS_MAP)
configs_map = configs.get_service_to_configs_map()
configs_expected = {
'ZooKeeper': ['zoo.cfg', 'zookeeper-env'],
'Knox': ['knox-env', 'ranger-knox-plugin-properties',
'gateway-site'],
'YARN': ['yarn-site', 'mapred-env', 'yarn-env',
'capacity-scheduler', 'mapred-site'],
'general': ['cluster-env'], 'Flume': ['flume-env'],
'Ambari': ['ams-hbase-policy', 'ams-site', 'ams-env',
'ams-hbase-site', 'ams-hbase-env',
'ams-hbase-security-site'],
'HDFS': ['core-site', 'ranger-hdfs-plugin-properties',
'hadoop-policy', 'hdfs-site', 'hadoop-env'],
'Ranger': ['ranger-env', 'admin-properties',
'usersync-properties', 'ranger-site'],
'Spark': ['spark-defaults', 'spark-env'],
'Hive': ['hive-env', 'hive-site', 'hiveserver2-site',
'ranger-hive-plugin-properties'],
'Storm': ['ranger-storm-plugin-properties', 'storm-site',
'storm-env'],
'Oozie': ['oozie-env', 'oozie-site', 'tez-site'],
'HBase': ['ranger-hbase-plugin-properties', 'hbase-env',
'hbase-site', 'hbase-policy'],
'Sqoop': ['sqoop-env'], 'Kafka': ['kafka-broker', 'kafka-env'],
'Falcon': ['falcon-startup.properties',
'falcon-runtime.properties', 'falcon-env']
}
for (key, item) in six.iteritems(configs_map):
item.sort()
for (key, item) in six.iteritems(configs_expected):
item.sort()
self.assertEqual(configs_map, configs_expected)
self.assertIsNotNone(configs.SERVICES_TO_CONFIGS_MAP)
def test_get_instance_params_default(self):
instance_configs = configs.get_instance_params(self.instance)
expected = [