http://git-wip-us.apache.org/repos/asf/ambari/blob/3f6c4ca0/ambari-server/src/test/python/custom_actions/TestInstallPackages.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/test/python/custom_actions/TestInstallPackages.py b/ambari-server/src/test/python/custom_actions/TestInstallPackages.py index 56a9fed..b31e2f5 100644 --- a/ambari-server/src/test/python/custom_actions/TestInstallPackages.py +++ b/ambari-server/src/test/python/custom_actions/TestInstallPackages.py @@ -21,7 +21,6 @@ import json import os import subprocess import select -import install_packages from mock.mock import patch from mock.mock import MagicMock @@ -45,6 +44,7 @@ subproc_mock.return_value = MagicMock() subproc_stdout = MagicMock() subproc_mock.return_value.stdout = subproc_stdout + @not_for_platform(PLATFORM_WINDOWS) @patch.object(os, "read", new=MagicMock(return_value=None)) @patch.object(select, "select", new=MagicMock(return_value=([subproc_stdout], None, None))) @@ -57,89 +57,101 @@ class TestInstallPackages(RMFTestCase): self.maxDiff = None @staticmethod - def _add_packages(arg): - arg.append(["pkg1", "1.0", "repo"]) - arg.append(["pkg2", "2.0", "repo2"]) + def _add_packages(*args): + return [ + ["pkg1", "1.0", "repo"], + ["pkg2", "2.0", "repo2"] + ] @staticmethod - def _add_packages_available(command, arg): - arg.append(["hadoop_2_2_0_1_885", "1.0", "HDP-2.2"]) - arg.append(["hadooplzo_2_2_0_1_885", "1.0", "HDP-2.2"]) - arg.append(["hadoop_2_2_0_1_885-libhdfs", "1.0", "HDP-2.2"]) + def _add_packages_available(*args): + return [ + ["hadoop_2_2_0_1_885", "1.0", "HDP-2.2"], + ["hadooplzo_2_2_0_1_885", "1.0", "HDP-2.2"], + ["hadoop_2_2_0_1_885-libhdfs", "1.0", "HDP-2.2"] + ] @staticmethod - def _add_packages_lookUpYum(command, key, arg): - TestInstallPackages._add_packages_available(command, arg) + def _add_packages_lookUpYum(*args): + return TestInstallPackages._add_packages_available(*args) @patch("resource_management.libraries.functions.list_ambari_managed_repos.list_ambari_managed_repos") - @patch("resource_management.libraries.functions.packages_analyzer._lookUpYumPackages") + @patch("resource_management.core.providers.get_provider") @patch("resource_management.libraries.script.Script.put_structured_out") @patch("resource_management.libraries.functions.stack_select.get_stack_versions") @patch("resource_management.libraries.functions.repo_version_history.read_actual_version_from_history_file") @patch("resource_management.libraries.functions.repo_version_history.write_actual_version_to_history_file") + @patch("ambari_commons.shell.subprocess_with_timeout") def test_normal_flow_rhel(self, + subprocess_with_timeout, write_actual_version_to_history_file_mock, read_actual_version_from_history_file_mock, stack_versions_mock, put_structured_out_mock, - lookUpYumPackages, list_ambari_managed_repos_mock): + get_provider, list_ambari_managed_repos_mock): stack_versions_mock.side_effect = [ [], # before installation attempt [VERSION_STUB] ] - lookUpYumPackages.side_effect = TestInstallPackages._add_packages_lookUpYum - list_ambari_managed_repos_mock.return_value=[] - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_file="install_packages_config.json", - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Redhat', '6.4', 'Final'), - ) - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'package_installation_result': 'SUCCESS', - 'repository_version_id': 1, - 'actual_version': VERSION_STUB}) - self.assertResourceCalled('Repository', 'HDP-UTILS-1.1.0.20', - base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', - action=['create'], - components=[u'HDP-UTILS', 'main'], - repo_template='[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', - repo_file_name=u'ambari-hdp-1', - mirror_list=None, - append_to_file=False, - ) - self.assertResourceCalled('Repository', 'HDP-2.2', - base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', - action=['create'], - components=[u'HDP', 'main'], - repo_template='[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', - repo_file_name=u'ambari-hdp-1', - mirror_list=None, - append_to_file=True, - ) - self.assertResourceCalled('Package', 'hdp-select', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'snappy', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'snappy-devel', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'lzo', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadooplzo_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885-libhdfs', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'ambari-log4j', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertNoMoreResources() + from resource_management.core.providers.package.yumrpm import YumProvider + provider = YumProvider(None) + with patch.object(provider, "_lookup_packages") as lookup_packages: + lookup_packages.side_effect = TestInstallPackages._add_packages_lookUpYum + get_provider.return_value = provider + list_ambari_managed_repos_mock.return_value=[] + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_file="install_packages_config.json", + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Redhat', '6.4', 'Final'), + ) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'package_installation_result': 'SUCCESS', + 'repository_version_id': 1, + 'actual_version': VERSION_STUB}) + self.assertResourceCalled('Repository', 'HDP-UTILS-1.1.0.20', + base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', + action=['create'], + components=[u'HDP-UTILS', 'main'], + repo_template='[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', + repo_file_name=u'ambari-hdp-1', + mirror_list=None, + append_to_file=False, + ) + self.assertResourceCalled('Repository', 'HDP-2.2', + base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', + action=['create'], + components=[u'HDP', 'main'], + repo_template='[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', + repo_file_name=u'ambari-hdp-1', + mirror_list=None, + append_to_file=True, + ) + self.assertResourceCalled('Package', 'hdp-select', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'snappy', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'snappy-devel', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'lzo', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadooplzo_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885-libhdfs', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'ambari-log4j', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertNoMoreResources() @patch("resource_management.libraries.functions.list_ambari_managed_repos.list_ambari_managed_repos") - @patch("resource_management.libraries.functions.packages_analyzer.allInstalledPackages") + @patch("resource_management.core.providers.get_provider") @patch("resource_management.libraries.script.Script.put_structured_out") @patch("resource_management.libraries.functions.stack_select.get_stack_versions") @patch("resource_management.libraries.functions.repo_version_history.read_actual_version_from_history_file") @patch("resource_management.libraries.functions.repo_version_history.write_actual_version_to_history_file") + @patch("ambari_commons.shell.subprocess_with_timeout") def test_no_repos(self, + subprocess_with_timeout, write_actual_version_to_history_file_mock, read_actual_version_from_history_file_mock, stack_versions_mock, - put_structured_out_mock, allInstalledPackages_mock, list_ambari_managed_repos_mock): + put_structured_out_mock, get_provider, list_ambari_managed_repos_mock): stack_versions_mock.side_effect = [ [], # before installation attempt [VERSION_STUB] @@ -151,156 +163,170 @@ class TestInstallPackages(RMFTestCase): command_json['repositoryFile']['repositories'] = [] - allInstalledPackages_mock.side_effect = TestInstallPackages._add_packages - list_ambari_managed_repos_mock.return_value=[] - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_dict = command_json, - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Redhat', '6.4', 'Final'), - ) - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'package_installation_result': 'SUCCESS', - 'repository_version_id': 1, - 'actual_version': VERSION_STUB}) - - self.assertResourceCalled('Package', 'hdp-select', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', None, action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'snappy', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'snappy-devel', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'lzo', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', None, action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', None, action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'ambari-log4j', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertNoMoreResources() + from resource_management.core.providers.package.yumrpm import YumProvider + provider = YumProvider(None) + with patch.object(provider, "_lookup_packages") as lookup_packages: + lookup_packages.side_effect = TestInstallPackages._add_packages + get_provider.return_value = provider + list_ambari_managed_repos_mock.return_value=[] + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_dict = command_json, + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Redhat', '6.4', 'Final'), + ) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'package_installation_result': 'SUCCESS', + 'repository_version_id': 1, + 'actual_version': VERSION_STUB}) + + self.assertResourceCalled('Package', 'hdp-select', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', None, action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'snappy', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'snappy-devel', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'lzo', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', None, action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', None, action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'ambari-log4j', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertNoMoreResources() @patch("ambari_commons.os_check.OSCheck.is_suse_family") @patch("resource_management.libraries.functions.list_ambari_managed_repos.list_ambari_managed_repos") - @patch("resource_management.libraries.functions.packages_analyzer._lookUpZypperPackages") + @patch("resource_management.core.providers.get_provider") @patch("resource_management.libraries.script.Script.put_structured_out") @patch("resource_management.libraries.functions.stack_select.get_stack_versions") @patch("resource_management.libraries.functions.repo_version_history.read_actual_version_from_history_file") @patch("resource_management.libraries.functions.repo_version_history.write_actual_version_to_history_file") - def test_normal_flow_sles(self, write_actual_version_to_history_file_mock, + @patch("ambari_commons.shell.subprocess_with_timeout") + def test_normal_flow_sles(self, subprocess_with_timeout, write_actual_version_to_history_file_mock, read_actual_version_from_history_file_mock, stack_versions_mock, put_structured_out_mock, - lookUpZypperPackages, list_ambari_managed_repos_mock, is_suse_family_mock): + get_provider, list_ambari_managed_repos_mock, is_suse_family_mock): is_suse_family_mock = True Script.stack_version_from_distro_select = VERSION_STUB stack_versions_mock.side_effect = [ [], # before installation attempt [VERSION_STUB] ] - lookUpZypperPackages.side_effect = TestInstallPackages._add_packages_available - list_ambari_managed_repos_mock.return_value=[] - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_file="install_packages_config.json", - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Suse', '11', 'SP1'), - ) - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'package_installation_result': 'SUCCESS', - 'repository_version_id': 1, - 'actual_version': VERSION_STUB}) - self.assertResourceCalled('Repository', 'HDP-UTILS-1.1.0.20', - base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', - action=['create'], - components=[u'HDP-UTILS', 'main'], - repo_template='[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', - repo_file_name=u'ambari-hdp-1', - mirror_list=None, - append_to_file=False, - ) - self.assertResourceCalled('Repository', 'HDP-2.2', - base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', - action=['create'], - components=[u'HDP', 'main'], - repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', - repo_file_name=u'ambari-hdp-1', - mirror_list=None, - append_to_file=True, - ) - self.assertResourceCalled('Package', 'hdp-select', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'snappy', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'snappy-devel', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'lzo', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadooplzo_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885-libhdfs', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'ambari-log4j', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertNoMoreResources() - + from resource_management.core.providers.package.yumrpm import YumProvider + provider = YumProvider(None) + with patch.object(provider, "_lookup_packages") as lookup_packages: + lookup_packages.side_effect = TestInstallPackages._add_packages_available + get_provider.return_value = provider + list_ambari_managed_repos_mock.return_value=[] + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_file="install_packages_config.json", + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Suse', '11', 'SP1'), + ) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'package_installation_result': 'SUCCESS', + 'repository_version_id': 1, + 'actual_version': VERSION_STUB}) + self.assertResourceCalled('Repository', 'HDP-UTILS-1.1.0.20', + base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', + action=['create'], + components=[u'HDP-UTILS', 'main'], + repo_template='[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', + repo_file_name=u'ambari-hdp-1', + mirror_list=None, + append_to_file=False, + ) + self.assertResourceCalled('Repository', 'HDP-2.2', + base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', + action=['create'], + components=[u'HDP', 'main'], + repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', + repo_file_name=u'ambari-hdp-1', + mirror_list=None, + append_to_file=True, + ) + self.assertResourceCalled('Package', 'hdp-select', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'snappy', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'snappy-devel', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'lzo', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadooplzo_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885-libhdfs', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'ambari-log4j', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertNoMoreResources() @patch("resource_management.libraries.functions.list_ambari_managed_repos.list_ambari_managed_repos") @patch("ambari_commons.os_check.OSCheck.is_redhat_family") @patch("resource_management.libraries.script.Script.put_structured_out") - @patch("resource_management.libraries.functions.packages_analyzer._lookUpYumPackages") + @patch("resource_management.core.providers.get_provider") @patch("resource_management.libraries.functions.stack_select.get_stack_versions") @patch("resource_management.libraries.functions.repo_version_history.read_actual_version_from_history_file") @patch("resource_management.libraries.functions.repo_version_history.write_actual_version_to_history_file") - def test_exclude_existing_repo(self, write_actual_version_to_history_file_mock, + @patch("ambari_commons.shell.subprocess_with_timeout") + def test_exclude_existing_repo(self, subprocess_with_timeout, write_actual_version_to_history_file_mock, read_actual_version_from_history_file_mock, stack_versions_mock, - lookUpYumPackages, put_structured_out_mock, + get_provider, put_structured_out_mock, is_redhat_family_mock, list_ambari_managed_repos_mock): stack_versions_mock.side_effect = [ [], # before installation attempt [VERSION_STUB] ] Script.stack_version_from_distro_select = VERSION_STUB - lookUpYumPackages.side_effect = TestInstallPackages._add_packages_lookUpYum - list_ambari_managed_repos_mock.return_value=["HDP-UTILS-2.2.0.1-885"] - is_redhat_family_mock.return_value = True - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_file="install_packages_config.json", - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Redhat', '6.4', 'Final'), - ) - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'package_installation_result': 'SUCCESS', - 'repository_version_id': 1, - 'actual_version': VERSION_STUB}) - self.assertResourceCalled('Repository', 'HDP-UTILS-1.1.0.20', - base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', - action=['create'], - components=[u'HDP-UTILS', 'main'], - repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', - repo_file_name='ambari-hdp-1', - mirror_list=None, - append_to_file=False, - ) - self.assertResourceCalled('Repository', 'HDP-2.2', - base_url='http://repo1/HDP/centos5/2.x/updates/2.2.0.0', - action=['create'], - components=[u'HDP', 'main'], - repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', - repo_file_name=u'ambari-hdp-1', - mirror_list=None, - append_to_file=True, - ) - self.assertResourceCalled('Package', 'hdp-select', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'snappy', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'snappy-devel', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'lzo', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadooplzo_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885-libhdfs', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'ambari-log4j', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertNoMoreResources() + from resource_management.core.providers.package.yumrpm import YumProvider + provider = YumProvider(None) + with patch.object(provider, "_lookup_packages") as lookup_packages: + lookup_packages.side_effect = TestInstallPackages._add_packages_lookUpYum + get_provider.return_value = provider + list_ambari_managed_repos_mock.return_value=["HDP-UTILS-2.2.0.1-885"] + is_redhat_family_mock.return_value = True + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_file="install_packages_config.json", + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Redhat', '6.4', 'Final'), + ) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'package_installation_result': 'SUCCESS', + 'repository_version_id': 1, + 'actual_version': VERSION_STUB}) + self.assertResourceCalled('Repository', 'HDP-UTILS-1.1.0.20', + base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', + action=['create'], + components=[u'HDP-UTILS', 'main'], + repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', + repo_file_name='ambari-hdp-1', + mirror_list=None, + append_to_file=False, + ) + self.assertResourceCalled('Repository', 'HDP-2.2', + base_url='http://repo1/HDP/centos5/2.x/updates/2.2.0.0', + action=['create'], + components=[u'HDP', 'main'], + repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', + repo_file_name=u'ambari-hdp-1', + mirror_list=None, + append_to_file=True, + ) + self.assertResourceCalled('Package', 'hdp-select', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'snappy', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'snappy-devel', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'lzo', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadooplzo_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885-libhdfs', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'ambari-log4j', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertNoMoreResources() _install_failed = False @staticmethod - def _add_packages_with_fail(arg): + def _add_packages_with_fail(): + arg = [] arg.append(["pkg1_2_2_0_1_885_pack", "1.0", "repo"]) arg.append(["pkg2_2_2_0_1_885_pack2", "2.0", "repo2"]) if TestInstallPackages._install_failed: @@ -310,6 +336,8 @@ class TestInstallPackages(RMFTestCase): arg.append(["ubuntu-like-2-2-0-1-885-fake-pkg", "3.0", "repo2"]) arg.append(["should_not_be_removed_pkg2", "3.0", "repo2"]) + return arg + @staticmethod def _new_with_exception(cls, name, env=None, provider=None, **kwargs): if (name != "snappy-devel"): @@ -320,63 +348,70 @@ class TestInstallPackages(RMFTestCase): @patch("resource_management.libraries.functions.list_ambari_managed_repos.list_ambari_managed_repos") @patch("ambari_commons.os_check.OSCheck.is_redhat_family") - @patch("resource_management.libraries.functions.packages_analyzer.allInstalledPackages") + @patch("resource_management.core.providers.get_provider") @patch("resource_management.core.resources.packaging.Package.__new__") @patch("resource_management.libraries.script.Script.put_structured_out") - def test_fail(self, put_structured_out_mock, Package__mock, allInstalledPackages_mock, + @patch("ambari_commons.shell.subprocess_with_timeout") + def test_fail(self, subprocess_with_timeout, put_structured_out_mock, Package__mock, get_provider, is_redhat_family_mock, list_ambari_managed_repos_mock): - allInstalledPackages_mock.side_effect = TestInstallPackages._add_packages_with_fail - is_redhat_family_mock.return_value = True - list_ambari_managed_repos_mock.return_value = [] - def side_effect(retcode): - TestInstallPackages._install_failed = True - raise Exception() - Package__mock.side_effect = side_effect - self.assertRaises(Fail, self.executeScript, "scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_file="install_packages_config.json", - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Redhat', '6.4', 'Final')) - - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'repository_version_id': 1, - 'package_installation_result': 'FAIL'}) - self.assertResourceCalled('Repository', 'HDP-UTILS-1.1.0.20', - base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', - action=['create'], - components=[u'HDP-UTILS', 'main'], - repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', - repo_file_name=u'ambari-hdp-1', - mirror_list=None, - append_to_file=False, - ) - self.assertResourceCalled('Repository', 'HDP-2.2', - base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', - action=['create'], - components=[u'HDP', 'main'], - repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', - repo_file_name=u'ambari-hdp-1', - mirror_list=None, - append_to_file=True, - ) - self.assertNoMoreResources() - - TestInstallPackages._install_failed = False + from resource_management.core.providers.package.yumrpm import YumProvider + provider = YumProvider(None) + with patch.object(provider, "_lookup_packages") as lookup_packages: + lookup_packages.side_effect = TestInstallPackages._add_packages_with_fail + is_redhat_family_mock.return_value = True + list_ambari_managed_repos_mock.return_value = [] + + def side_effect(retcode): + TestInstallPackages._install_failed = True + raise Exception() + + Package__mock.side_effect = side_effect + self.assertRaises(Fail, self.executeScript, "scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_file="install_packages_config.json", + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Redhat', '6.4', 'Final')) + + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'repository_version_id': 1, + 'package_installation_result': 'FAIL'}) + self.assertResourceCalled('Repository', 'HDP-UTILS-1.1.0.20', + base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', + action=['create'], + components=[u'HDP-UTILS', 'main'], + repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', + repo_file_name=u'ambari-hdp-1', + mirror_list=None, + append_to_file=False, + ) + self.assertResourceCalled('Repository', 'HDP-2.2', + base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', + action=['create'], + components=[u'HDP', 'main'], + repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', + repo_file_name=u'ambari-hdp-1', + mirror_list=None, + append_to_file=True, + ) + self.assertNoMoreResources() + + TestInstallPackages._install_failed = False @patch("ambari_commons.os_check.OSCheck.is_suse_family") @patch("resource_management.core.resources.packaging.Package") @patch("resource_management.libraries.script.Script.put_structured_out") - @patch("resource_management.libraries.functions.packages_analyzer._lookUpZypperPackages") + @patch("resource_management.core.providers.get_provider") @patch("resource_management.libraries.functions.stack_select.get_stack_versions") @patch("resource_management.libraries.functions.repo_version_history.read_actual_version_from_history_file") @patch("resource_management.libraries.functions.repo_version_history.write_actual_version_to_history_file") - def test_format_package_name(self, write_actual_version_to_history_file_mock, + @patch("ambari_commons.shell.subprocess_with_timeout") + def test_format_package_name(self, subprocess_with_timeout, write_actual_version_to_history_file_mock, read_actual_version_from_history_file_mock, stack_versions_mock, - lookUpZypperPackages, put_structured_out_mock, + get_provider, put_structured_out_mock, package_mock, is_suse_family_mock): Script.stack_version_from_distro_select = VERSION_STUB stack_versions_mock.side_effect = [ @@ -384,61 +419,67 @@ class TestInstallPackages(RMFTestCase): [VERSION_STUB] ] read_actual_version_from_history_file_mock.return_value = VERSION_STUB - lookUpZypperPackages.side_effect = TestInstallPackages._add_packages_available - is_suse_family_mock.return_value = True - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_file="install_packages_config.json", - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Suse', '11', 'Final'), - ) - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'package_installation_result': 'SUCCESS', - 'repository_version_id': 1, - 'actual_version': VERSION_STUB}) - self.assertResourceCalled('Repository', 'HDP-UTILS-1.1.0.20', - base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', - action=['create'], - components=[u'HDP-UTILS', 'main'], - repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', - repo_file_name=u'ambari-hdp-1', - mirror_list=None, - append_to_file=False, - ) - self.assertResourceCalled('Repository', 'HDP-2.2', - base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', - action=['create'], - components=[u'HDP', 'main'], - repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', - repo_file_name=u'ambari-hdp-1', - mirror_list=None, - append_to_file=True, - ) - self.assertResourceCalled('Package', 'hdp-select', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'snappy', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'snappy-devel', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'lzo', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadooplzo_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885-libhdfs', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'ambari-log4j', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertNoMoreResources() + from resource_management.core.providers.package.yumrpm import YumProvider + provider = YumProvider(None) + with patch.object(provider, "_lookup_packages") as lookup_packages: + lookup_packages.side_effect = TestInstallPackages._add_packages_available + + get_provider.return_value = provider + is_suse_family_mock.return_value = True + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_file="install_packages_config.json", + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Suse', '11', 'Final'), + ) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'package_installation_result': 'SUCCESS', + 'repository_version_id': 1, + 'actual_version': VERSION_STUB}) + self.assertResourceCalled('Repository', 'HDP-UTILS-1.1.0.20', + base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', + action=['create'], + components=[u'HDP-UTILS', 'main'], + repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', + repo_file_name=u'ambari-hdp-1', + mirror_list=None, + append_to_file=False, + ) + self.assertResourceCalled('Repository', 'HDP-2.2', + base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', + action=['create'], + components=[u'HDP', 'main'], + repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', + repo_file_name=u'ambari-hdp-1', + mirror_list=None, + append_to_file=True, + ) + self.assertResourceCalled('Package', 'hdp-select', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'snappy', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'snappy-devel', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'lzo', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadooplzo_2_2_0_1_885', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885-libhdfs', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'ambari-log4j', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertNoMoreResources() @patch("ambari_commons.os_check.OSCheck.is_suse_family") @patch("resource_management.core.resources.packaging.Package") @patch("resource_management.libraries.script.Script.put_structured_out") - @patch("resource_management.libraries.functions.packages_analyzer._lookUpZypperPackages") + @patch("resource_management.core.providers.get_provider") @patch("resource_management.libraries.functions.stack_select.get_stack_versions") @patch("resource_management.libraries.functions.repo_version_history.read_actual_version_from_history_file") @patch("resource_management.libraries.functions.repo_version_history.write_actual_version_to_history_file") - def test_format_package_name_via_repositoryFile(self, write_actual_version_to_history_file_mock, + @patch("ambari_commons.shell.subprocess_with_timeout") + def test_format_package_name_via_repositoryFile(self, subprocess_with_timeout, write_actual_version_to_history_file_mock, read_actual_version_from_history_file_mock, stack_versions_mock, - lookUpZypperPackages, put_structured_out_mock, + get_provider, put_structured_out_mock, package_mock, is_suse_family_mock): Script.stack_version_from_distro_select = VERSION_STUB stack_versions_mock.side_effect = [ @@ -446,71 +487,75 @@ class TestInstallPackages(RMFTestCase): [VERSION_STUB] ] read_actual_version_from_history_file_mock.return_value = VERSION_STUB - lookUpZypperPackages.side_effect = TestInstallPackages._add_packages_available - is_suse_family_mock.return_value = True + from resource_management.core.providers.package.yumrpm import YumProvider + provider = YumProvider(None) + with patch.object(provider, "_lookup_packages") as lookup_packages: + lookup_packages.side_effect = TestInstallPackages._add_packages_available + get_provider.return_value = provider + is_suse_family_mock.return_value = True - config_file = self.get_src_folder() + "/test/python/custom_actions/configs/install_packages_repository_file.json" - with open(config_file, "r") as f: - command_json = json.load(f) + config_file = self.get_src_folder() + "/test/python/custom_actions/configs/install_packages_repository_file.json" + with open(config_file, "r") as f: + command_json = json.load(f) - command_json['repositoryFile']['repoVersion'] = '2.2.0.1-990' - - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_dict=command_json, - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Suse', '11', 'Final'), - ) - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'package_installation_result': 'SUCCESS', - 'repository_version_id': 4, - 'actual_version': VERSION_STUB}) - self.assertResourceCalled('Repository', 'HDP-UTILS-1.1.0.20-repo-4', - base_url=u'http://repo1/HDP-UTILS/centos5/2.x/updates/2.2.0.0', - action=['create'], - components=[u'HDP-UTILS', 'main'], - repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', - repo_file_name=u'ambari-hdp-4', - mirror_list=None, - append_to_file=False, - ) - self.assertResourceCalled('Repository', 'HDP-2.2-repo-4', - base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', - action=['create'], - components=[u'HDP', 'main'], - repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', - repo_file_name=u'ambari-hdp-4', - mirror_list=None, - append_to_file=True, - ) - self.assertResourceCalled('Package', 'hdp-select', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885', action=["upgrade"], retry_count=5, - retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'snappy', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'snappy-devel', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'lzo', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadooplzo_2_2_0_1_885', action=["upgrade"], retry_count=5, - retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885-libhdfs', action=["upgrade"], retry_count=5, - retry_on_repo_unavailability=False) - self.assertResourceCalled('Package', 'ambari-log4j', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) - self.assertNoMoreResources() + command_json['repositoryFile']['repoVersion'] = '2.2.0.1-990' + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_dict=command_json, + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Suse', '11', 'Final'), + ) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'package_installation_result': 'SUCCESS', + 'repository_version_id': 4, + 'actual_version': VERSION_STUB}) + self.assertResourceCalled('Repository', 'HDP-UTILS-1.1.0.20-repo-4', + base_url=u'http://repo1/HDP-UTILS/centos5/2.x/updates/2.2.0.0', + action=['create'], + components=[u'HDP-UTILS', 'main'], + repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', + repo_file_name=u'ambari-hdp-4', + mirror_list=None, + append_to_file=False, + ) + self.assertResourceCalled('Repository', 'HDP-2.2-repo-4', + base_url=u'http://repo1/HDP/centos5/2.x/updates/2.2.0.0', + action=['create'], + components=[u'HDP', 'main'], + repo_template=u'[{{repo_id}}]\nname={{repo_id}}\n{% if mirror_list %}mirrorlist={{mirror_list}}{% else %}baseurl={{base_url}}{% endif %}\n\npath=/\nenabled=1\ngpgcheck=0', + repo_file_name=u'ambari-hdp-4', + mirror_list=None, + append_to_file=True, + ) + self.assertResourceCalled('Package', 'hdp-select', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885', action=["upgrade"], retry_count=5, + retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'snappy', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'snappy-devel', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'lzo', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadooplzo_2_2_0_1_885', action=["upgrade"], retry_count=5, + retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'hadoop_2_2_0_1_885-libhdfs', action=["upgrade"], retry_count=5, + retry_on_repo_unavailability=False) + self.assertResourceCalled('Package', 'ambari-log4j', action=["upgrade"], retry_count=5, retry_on_repo_unavailability=False) + self.assertNoMoreResources() @patch("resource_management.libraries.functions.list_ambari_managed_repos.list_ambari_managed_repos") - @patch("resource_management.libraries.functions.packages_analyzer.allInstalledPackages") + @patch("resource_management.core.providers.get_provider") @patch("resource_management.libraries.script.Script.put_structured_out") @patch("resource_management.libraries.functions.stack_select.get_stack_versions") @patch("resource_management.libraries.functions.repo_version_history.read_actual_version_from_history_file") @patch("resource_management.libraries.functions.repo_version_history.write_actual_version_to_history_file") - def test_version_reporting__build_number_defined(self, - write_actual_version_to_history_file_mock, - read_actual_version_from_history_file_mock, - stack_versions_mock, - put_structured_out_mock, allInstalledPackages_mock, list_ambari_managed_repos_mock): + @patch("ambari_commons.shell.subprocess_with_timeout") + def test_version_reporting__build_number_defined(self, subprocess_with_timeout, + write_actual_version_to_history_file_mock, + read_actual_version_from_history_file_mock, + stack_versions_mock, + put_structured_out_mock, get_provider, list_ambari_managed_repos_mock): stack_versions_mock.side_effect = [ [OLD_VERSION_STUB], # before installation attempt [OLD_VERSION_STUB, VERSION_STUB] @@ -522,71 +567,77 @@ class TestInstallPackages(RMFTestCase): command_json['repositoryFile']['repoVersion'] = VERSION_STUB - allInstalledPackages_mock.side_effect = TestInstallPackages._add_packages - list_ambari_managed_repos_mock.return_value = [] - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_dict=command_json, - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Redhat', '6.4', 'Final'), - ) - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'package_installation_result': 'SUCCESS', - 'repository_version_id': 1, - 'actual_version': VERSION_STUB}) - self.assertTrue(write_actual_version_to_history_file_mock.called) - self.assertEquals(write_actual_version_to_history_file_mock.call_args[0], (VERSION_STUB_WITHOUT_BUILD_NUMBER, VERSION_STUB)) - - stack_versions_mock.reset_mock() - write_actual_version_to_history_file_mock.reset_mock() - put_structured_out_mock.reset_mock() - - # Test retrying install again - stack_versions_mock.side_effect = [ - [OLD_VERSION_STUB, VERSION_STUB], - [OLD_VERSION_STUB, VERSION_STUB] - ] - read_actual_version_from_history_file_mock.return_value = VERSION_STUB - - config_file = self.get_src_folder() + "/test/python/custom_actions/configs/install_packages_config.json" - with open(config_file, "r") as f: - command_json = json.load(f) - - command_json['repositoryFile']['repoVersion'] = VERSION_STUB - - allInstalledPackages_mock.side_effect = TestInstallPackages._add_packages - list_ambari_managed_repos_mock.return_value = [] - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_dict=command_json, - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Redhat', '6.4', 'Final'), - ) - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'package_installation_result': 'SUCCESS', - 'repository_version_id': 1, - 'actual_version': VERSION_STUB}) + from resource_management.core.providers.package.yumrpm import YumProvider + provider = YumProvider(None) + with patch.object(provider, "_lookup_packages") as lookup_packages: + lookup_packages.side_effect = TestInstallPackages._add_packages + get_provider.return_value = provider + list_ambari_managed_repos_mock.return_value = [] + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_dict=command_json, + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Redhat', '6.4', 'Final'), + ) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'package_installation_result': 'SUCCESS', + 'repository_version_id': 1, + 'actual_version': VERSION_STUB}) + self.assertTrue(write_actual_version_to_history_file_mock.called) + self.assertEquals(write_actual_version_to_history_file_mock.call_args[0], (VERSION_STUB_WITHOUT_BUILD_NUMBER, VERSION_STUB)) + + stack_versions_mock.reset_mock() + write_actual_version_to_history_file_mock.reset_mock() + put_structured_out_mock.reset_mock() + + # Test retrying install again + stack_versions_mock.side_effect = [ + [OLD_VERSION_STUB, VERSION_STUB], + [OLD_VERSION_STUB, VERSION_STUB] + ] + read_actual_version_from_history_file_mock.return_value = VERSION_STUB + + config_file = self.get_src_folder() + "/test/python/custom_actions/configs/install_packages_config.json" + with open(config_file, "r") as f: + command_json = json.load(f) + + command_json['repositoryFile']['repoVersion'] = VERSION_STUB + + lookup_packages.side_effect = TestInstallPackages._add_packages + list_ambari_managed_repos_mock.return_value = [] + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_dict=command_json, + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Redhat', '6.4', 'Final'), + ) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'package_installation_result': 'SUCCESS', + 'repository_version_id': 1, + 'actual_version': VERSION_STUB}) - self.assertFalse(write_actual_version_to_history_file_mock.called) + self.assertFalse(write_actual_version_to_history_file_mock.called) @patch("resource_management.libraries.functions.list_ambari_managed_repos.list_ambari_managed_repos") - @patch("resource_management.libraries.functions.packages_analyzer.allInstalledPackages") + @patch("resource_management.core.providers.get_provider") @patch("resource_management.libraries.script.Script.put_structured_out") @patch("resource_management.libraries.functions.stack_select.get_stack_versions") @patch("resource_management.libraries.functions.repo_version_history.read_actual_version_from_history_file") @patch("resource_management.libraries.functions.repo_version_history.write_actual_version_to_history_file") @patch("os.path.exists") + @patch("ambari_commons.shell.subprocess_with_timeout") def test_version_reporting__build_number_not_defined_stack_root_present__no_components_installed(self, + subprocess_with_timeout, exists_mock, write_actual_version_to_history_file_mock, read_actual_version_from_history_file_mock, stack_versions_mock, - put_structured_out_mock, allInstalledPackages_mock, list_ambari_managed_repos_mock): + put_structured_out_mock, get_provider, list_ambari_managed_repos_mock): exists_mock.return_value = True stack_versions_mock.side_effect = [ [], # before installation attempt @@ -600,48 +651,54 @@ class TestInstallPackages(RMFTestCase): command_json['roleParams']['repository_version'] = VERSION_STUB_WITHOUT_BUILD_NUMBER - allInstalledPackages_mock.side_effect = TestInstallPackages._add_packages - list_ambari_managed_repos_mock.return_value = [] + from resource_management.core.providers.package.yumrpm import YumProvider + provider = YumProvider(None) + with patch.object(provider, "_lookup_packages") as lookup_packages: + lookup_packages.side_effect = TestInstallPackages._add_packages + get_provider.return_value = provider + list_ambari_managed_repos_mock.return_value = [] - try: - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_dict=command_json, - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Redhat', '6.4', 'Final'), - ) - self.fail("Should throw exception") - except Fail: - pass # Expected + try: + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_dict=command_json, + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Redhat', '6.4', 'Final'), + ) + self.fail("Should throw exception") + except Fail: + pass # Expected - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args_list[-1][0][0], - { 'actual_version': '2.2.0.1-885', - 'package_installation_result': 'FAIL', - 'repository_version_id': 1}) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args_list[-1][0][0], + { 'actual_version': '2.2.0.1-885', + 'package_installation_result': 'FAIL', + 'repository_version_id': 1}) - self.assertFalse(write_actual_version_to_history_file_mock.called) + self.assertFalse(write_actual_version_to_history_file_mock.called) - stack_versions_mock.reset_mock() - write_actual_version_to_history_file_mock.reset_mock() - put_structured_out_mock.reset_mock() + stack_versions_mock.reset_mock() + write_actual_version_to_history_file_mock.reset_mock() + put_structured_out_mock.reset_mock() @patch("resource_management.libraries.functions.list_ambari_managed_repos.list_ambari_managed_repos") - @patch("resource_management.libraries.functions.packages_analyzer.allInstalledPackages") + @patch("resource_management.core.providers.get_provider") @patch("resource_management.libraries.script.Script.put_structured_out") @patch("resource_management.libraries.functions.stack_select.get_stack_versions") @patch("resource_management.libraries.functions.repo_version_history.read_actual_version_from_history_file") @patch("resource_management.libraries.functions.repo_version_history.write_actual_version_to_history_file") @patch("os.path.exists") + @patch("ambari_commons.shell.subprocess_with_timeout") def test_version_reporting__build_number_not_defined_stack_root_absent(self, + subprocess_with_timeout, exists_mock, write_actual_version_to_history_file_mock, read_actual_version_from_history_file_mock, stack_versions_mock, - put_structured_out_mock, allInstalledPackages_mock, list_ambari_managed_repos_mock): + put_structured_out_mock, get_provider, list_ambari_managed_repos_mock): exists_mock.return_value = False stack_versions_mock.side_effect = [ [], # before installation attempt @@ -655,79 +712,86 @@ class TestInstallPackages(RMFTestCase): command_json['repositoryFile']['repoVersion'] = VERSION_STUB_WITHOUT_BUILD_NUMBER - allInstalledPackages_mock.side_effect = TestInstallPackages._add_packages - list_ambari_managed_repos_mock.return_value = [] - try: - self.executeScript("scripts/install_packages.py", + from resource_management.core.providers.package.yumrpm import YumProvider + provider = YumProvider(None) + with patch.object(provider, "_lookup_packages") as lookup_packages: + lookup_packages.side_effect = TestInstallPackages._add_packages + get_provider.return_value = provider + + list_ambari_managed_repos_mock.return_value = [] + try: + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_dict=command_json, + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Redhat', '6.4', 'Final'), + ) + self.fail("Should throw exception") + except Fail: + pass # Expected + + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args_list[-1][0][0], + {'package_installation_result': 'FAIL', + 'repository_version_id': 1}) + + self.assertFalse(write_actual_version_to_history_file_mock.called) + + stack_versions_mock.reset_mock() + write_actual_version_to_history_file_mock.reset_mock() + put_structured_out_mock.reset_mock() + + # Test retrying install again (correct build number, provided by other nodes, is now received from server) + + stack_versions_mock.side_effect = [ + [], # before installation attempt + [] + ] + read_actual_version_from_history_file_mock.return_value = None + + config_file = self.get_src_folder() + "/test/python/custom_actions/configs/install_packages_config.json" + with open(config_file, "r") as f: + command_json = json.load(f) + + command_json['repositoryFile']['repoVersion'] = VERSION_STUB + + lookup_packages.side_effect = TestInstallPackages._add_packages + list_ambari_managed_repos_mock.return_value = [] + try: + self.executeScript("scripts/install_packages.py", classname="InstallPackages", command="actionexecute", config_dict=command_json, target=RMFTestCase.TARGET_CUSTOM_ACTIONS, os_type=('Redhat', '6.4', 'Final'), ) - self.fail("Should throw exception") - except Fail: - pass # Expected + self.fail("Should throw exception") + except Fail: + pass # Expected - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args_list[-1][0][0], - {'package_installation_result': 'FAIL', - 'repository_version_id': 1}) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'package_installation_result': 'FAIL', + 'repository_version_id': 1, + 'actual_version': VERSION_STUB}) - self.assertFalse(write_actual_version_to_history_file_mock.called) - - stack_versions_mock.reset_mock() - write_actual_version_to_history_file_mock.reset_mock() - put_structured_out_mock.reset_mock() - - # Test retrying install again (correct build number, provided by other nodes, is now received from server) - - stack_versions_mock.side_effect = [ - [], # before installation attempt - [] - ] - read_actual_version_from_history_file_mock.return_value = None - - config_file = self.get_src_folder() + "/test/python/custom_actions/configs/install_packages_config.json" - with open(config_file, "r") as f: - command_json = json.load(f) - - command_json['repositoryFile']['repoVersion'] = VERSION_STUB - - allInstalledPackages_mock.side_effect = TestInstallPackages._add_packages - list_ambari_managed_repos_mock.return_value = [] - try: - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_dict=command_json, - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Redhat', '6.4', 'Final'), - ) - self.fail("Should throw exception") - except Fail: - pass # Expected - - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'package_installation_result': 'FAIL', - 'repository_version_id': 1, - 'actual_version': VERSION_STUB}) - - self.assertFalse(write_actual_version_to_history_file_mock.called) + self.assertFalse(write_actual_version_to_history_file_mock.called) @patch("resource_management.libraries.functions.list_ambari_managed_repos.list_ambari_managed_repos") - @patch("resource_management.libraries.functions.packages_analyzer.allInstalledPackages") + @patch("resource_management.core.providers.get_provider") @patch("resource_management.libraries.script.Script.put_structured_out") @patch("resource_management.libraries.functions.stack_select.get_stack_versions") @patch("resource_management.libraries.functions.repo_version_history.read_actual_version_from_history_file") @patch("resource_management.libraries.functions.repo_version_history.write_actual_version_to_history_file") + @patch("ambari_commons.shell.subprocess_with_timeout") def test_version_reporting__build_number_not_defined_stack_root_present(self, + subprocess_with_timeout, write_actual_version_to_history_file_mock, read_actual_version_from_history_file_mock, stack_versions_mock, - put_structured_out_mock, allInstalledPackages_mock, list_ambari_managed_repos_mock): + put_structured_out_mock, get_provider, list_ambari_managed_repos_mock): stack_versions_mock.side_effect = [ [OLD_VERSION_STUB], # before installation attempt [OLD_VERSION_STUB, VERSION_STUB] @@ -739,69 +803,75 @@ class TestInstallPackages(RMFTestCase): command_json['roleParams']['repository_version'] = VERSION_STUB_WITHOUT_BUILD_NUMBER - allInstalledPackages_mock.side_effect = TestInstallPackages._add_packages - list_ambari_managed_repos_mock.return_value = [] - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_dict=command_json, - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Redhat', '6.4', 'Final'), - ) - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'package_installation_result': 'SUCCESS', - 'repository_version_id': 1, - 'actual_version': VERSION_STUB}) - self.assertTrue(write_actual_version_to_history_file_mock.called) - self.assertEquals(write_actual_version_to_history_file_mock.call_args[0], (VERSION_STUB_WITHOUT_BUILD_NUMBER, VERSION_STUB)) - - stack_versions_mock.reset_mock() - write_actual_version_to_history_file_mock.reset_mock() - put_structured_out_mock.reset_mock() - - # Test retrying install again - stack_versions_mock.side_effect = [ - [OLD_VERSION_STUB, VERSION_STUB], - [OLD_VERSION_STUB, VERSION_STUB] - ] - read_actual_version_from_history_file_mock.return_value = VERSION_STUB - - config_file = self.get_src_folder() + "/test/python/custom_actions/configs/install_packages_config.json" - with open(config_file, "r") as f: - command_json = json.load(f) - - command_json['repositoryFile']['repoVersion'] = VERSION_STUB_WITHOUT_BUILD_NUMBER - - allInstalledPackages_mock.side_effect = TestInstallPackages._add_packages - list_ambari_managed_repos_mock.return_value = [] - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_dict=command_json, - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Redhat', '6.4', 'Final'), - ) - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'package_installation_result': 'SUCCESS', - 'repository_version_id': 1, - 'actual_version': VERSION_STUB}) + from resource_management.core.providers.package.yumrpm import YumProvider + provider = YumProvider(None) + with patch.object(provider, "_lookup_packages") as lookup_packages: + lookup_packages.side_effect = TestInstallPackages._add_packages + get_provider.return_value = provider + list_ambari_managed_repos_mock.return_value = [] + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_dict=command_json, + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Redhat', '6.4', 'Final'), + ) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'package_installation_result': 'SUCCESS', + 'repository_version_id': 1, + 'actual_version': VERSION_STUB}) + self.assertTrue(write_actual_version_to_history_file_mock.called) + self.assertEquals(write_actual_version_to_history_file_mock.call_args[0], (VERSION_STUB_WITHOUT_BUILD_NUMBER, VERSION_STUB)) + + stack_versions_mock.reset_mock() + write_actual_version_to_history_file_mock.reset_mock() + put_structured_out_mock.reset_mock() + + # Test retrying install again + stack_versions_mock.side_effect = [ + [OLD_VERSION_STUB, VERSION_STUB], + [OLD_VERSION_STUB, VERSION_STUB] + ] + read_actual_version_from_history_file_mock.return_value = VERSION_STUB + + config_file = self.get_src_folder() + "/test/python/custom_actions/configs/install_packages_config.json" + with open(config_file, "r") as f: + command_json = json.load(f) + + command_json['repositoryFile']['repoVersion'] = VERSION_STUB_WITHOUT_BUILD_NUMBER + + lookup_packages.side_effect = TestInstallPackages._add_packages + list_ambari_managed_repos_mock.return_value = [] + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_dict=command_json, + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Redhat', '6.4', 'Final'), + ) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'package_installation_result': 'SUCCESS', + 'repository_version_id': 1, + 'actual_version': VERSION_STUB}) - self.assertFalse(write_actual_version_to_history_file_mock.called) + self.assertFalse(write_actual_version_to_history_file_mock.called) @patch("resource_management.libraries.functions.list_ambari_managed_repos.list_ambari_managed_repos") - @patch("resource_management.libraries.functions.packages_analyzer.allInstalledPackages") + @patch("resource_management.core.providers.get_provider") @patch("resource_management.libraries.script.Script.put_structured_out") @patch("resource_management.libraries.functions.stack_select.get_stack_versions") @patch("resource_management.libraries.functions.repo_version_history.read_actual_version_from_history_file") @patch("resource_management.libraries.functions.repo_version_history.write_actual_version_to_history_file") + @patch("ambari_commons.shell.subprocess_with_timeout") def test_version_reporting__wrong_build_number_specified_stack_root_present(self, + subprocess_with_timeout, write_actual_version_to_history_file_mock, read_actual_version_from_history_file_mock, stack_versions_mock, - put_structured_out_mock, allInstalledPackages_mock, list_ambari_managed_repos_mock): + put_structured_out_mock, get_provider, list_ambari_managed_repos_mock): stack_versions_mock.side_effect = [ [OLD_VERSION_STUB], # before installation attempt [OLD_VERSION_STUB, VERSION_STUB] @@ -813,71 +883,77 @@ class TestInstallPackages(RMFTestCase): command_json['repositoryFile']['repoVersion'] = '2.2.0.1-500' # User specified wrong build number - allInstalledPackages_mock.side_effect = TestInstallPackages._add_packages - list_ambari_managed_repos_mock.return_value = [] - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_dict=command_json, - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Redhat', '6.4', 'Final'), - ) - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'package_installation_result': 'SUCCESS', - 'repository_version_id': 1, - 'actual_version': VERSION_STUB}) - self.assertTrue(write_actual_version_to_history_file_mock.called) - self.assertEquals(write_actual_version_to_history_file_mock.call_args[0], ('2.2.0.1', VERSION_STUB)) - - stack_versions_mock.reset_mock() - write_actual_version_to_history_file_mock.reset_mock() - put_structured_out_mock.reset_mock() - - # Test retrying install again - stack_versions_mock.side_effect = [ - [OLD_VERSION_STUB, VERSION_STUB], - [OLD_VERSION_STUB, VERSION_STUB] - ] - read_actual_version_from_history_file_mock.return_value = VERSION_STUB - - config_file = self.get_src_folder() + "/test/python/custom_actions/configs/install_packages_config.json" - with open(config_file, "r") as f: - command_json = json.load(f) - - command_json['roleParams']['repository_version'] = '2.2.0.1-500' # User specified wrong build number - - allInstalledPackages_mock.side_effect = TestInstallPackages._add_packages - list_ambari_managed_repos_mock.return_value = [] - self.executeScript("scripts/install_packages.py", - classname="InstallPackages", - command="actionexecute", - config_dict=command_json, - target=RMFTestCase.TARGET_CUSTOM_ACTIONS, - os_type=('Redhat', '6.4', 'Final'), - ) - self.assertTrue(put_structured_out_mock.called) - self.assertEquals(put_structured_out_mock.call_args[0][0], - {'package_installation_result': 'SUCCESS', - 'repository_version_id': 1, - 'actual_version': VERSION_STUB}) + from resource_management.core.providers.package.yumrpm import YumProvider + provider = YumProvider(None) + with patch.object(provider, "_lookup_packages") as lookup_packages: + lookup_packages.side_effect = TestInstallPackages._add_packages + get_provider.return_value = provider + list_ambari_managed_repos_mock.return_value = [] + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_dict=command_json, + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Redhat', '6.4', 'Final'), + ) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'package_installation_result': 'SUCCESS', + 'repository_version_id': 1, + 'actual_version': VERSION_STUB}) + self.assertTrue(write_actual_version_to_history_file_mock.called) + self.assertEquals(write_actual_version_to_history_file_mock.call_args[0], ('2.2.0.1', VERSION_STUB)) + + stack_versions_mock.reset_mock() + write_actual_version_to_history_file_mock.reset_mock() + put_structured_out_mock.reset_mock() + + # Test retrying install again + stack_versions_mock.side_effect = [ + [OLD_VERSION_STUB, VERSION_STUB], + [OLD_VERSION_STUB, VERSION_STUB] + ] + read_actual_version_from_history_file_mock.return_value = VERSION_STUB + + config_file = self.get_src_folder() + "/test/python/custom_actions/configs/install_packages_config.json" + with open(config_file, "r") as f: + command_json = json.load(f) + + command_json['roleParams']['repository_version'] = '2.2.0.1-500' # User specified wrong build number + + lookup_packages.side_effect = TestInstallPackages._add_packages + list_ambari_managed_repos_mock.return_value = [] + self.executeScript("scripts/install_packages.py", + classname="InstallPackages", + command="actionexecute", + config_dict=command_json, + target=RMFTestCase.TARGET_CUSTOM_ACTIONS, + os_type=('Redhat', '6.4', 'Final'), + ) + self.assertTrue(put_structured_out_mock.called) + self.assertEquals(put_structured_out_mock.call_args[0][0], + {'package_installation_result': 'SUCCESS', + 'repository_version_id': 1, + 'actual_version': VERSION_STUB}) - self.assertFalse(write_actual_version_to_history_file_mock.called) + self.assertFalse(write_actual_version_to_history_file_mock.called) @patch("resource_management.libraries.functions.list_ambari_managed_repos.list_ambari_managed_repos") - @patch("resource_management.libraries.functions.packages_analyzer.allInstalledPackages") + @patch("resource_management.core.providers.get_provider") @patch("resource_management.libraries.script.Script.put_structured_out") @patch("resource_management.libraries.functions.stack_select.get_stack_versions") @patch("resource_management.libraries.functions.repo_version_history.read_actual_version_from_history_file") @patch("resource_management.libraries.functions.repo_version_history.write_actual_version_to_history_file") @patch("os.path.exists") + @patch("ambari_commons.shell.subprocess_with_timeout") def test_version_reporting__wrong_build_number_specified_stack_root_absent(self, + subprocess_with_timeout, exists_mock,
<TRUNCATED>
