From 17ee702791e8904ddf9135be03ec58acce9ce3c2 Mon Sep 17 00:00:00 2001 From: Kevin Bates Date: Thu, 25 Jul 2019 15:06:52 -0700 Subject: [PATCH] Release 0.3.6 Prepare for release 0.3.6. Aside from updating the version and changelog, this also includes minor updates to a few test files to satisfy lint. --- README.rst | 4 ++++ tests/test_hadoop_conf.py | 2 -- tests/test_node_manager.py | 2 +- tests/test_resource_manager.py | 8 ++++---- yarn_api_client/__init__.py | 2 +- 5 files changed, 10 insertions(+), 8 deletions(-) diff --git a/README.rst b/README.rst index 6abfc53..d4c496e 100644 --- a/README.rst +++ b/README.rst @@ -88,6 +88,10 @@ Programmatic interface Changelog ========= +0.3.6 Release + - Extend ResourceManager to allow applications to better + determine resource availability prior to submission. + 0.3.5 Release - Hotfix release to fix internal signature mismatch diff --git a/tests/test_hadoop_conf.py b/tests/test_hadoop_conf.py index a859e98..3a1f0ff 100644 --- a/tests/test_hadoop_conf.py +++ b/tests/test_hadoop_conf.py @@ -165,7 +165,6 @@ def test_get_jobhistory_host_port(self): host_port = hadoop_conf.get_jobhistory_host_port() self.assertIsNone(host_port) - def test_get_nodemanager_host_port(self): with patch('yarn_api_client.hadoop_conf.parse') as parse_mock: parse_mock.return_value = 'example.com:8022' @@ -182,7 +181,6 @@ def test_get_nodemanager_host_port(self): host_port = hadoop_conf.get_nodemanager_host_port() self.assertIsNone(host_port) - def test_get_webproxy_host_port(self): with patch('yarn_api_client.hadoop_conf.parse') as parse_mock: parse_mock.return_value = 'example.com:8022' diff --git a/tests/test_node_manager.py b/tests/test_node_manager.py index 94e3034..c602bd3 100644 --- a/tests/test_node_manager.py +++ b/tests/test_node_manager.py @@ -18,7 +18,7 @@ def test_node_information(self, request_mock): def test_node_applications(self, request_mock): self.nm.node_applications('RUNNING', 'root') request_mock.assert_called_with('/ws/v1/node/apps', - params={"state":'RUNNING', "user":'root'}) + params={"state": 'RUNNING', "user": 'root'}) self.nm.node_applications() request_mock.assert_called_with('/ws/v1/node/apps', params={}) diff --git a/tests/test_resource_manager.py b/tests/test_resource_manager.py index ec264fe..0b20736 100644 --- a/tests/test_resource_manager.py +++ b/tests/test_resource_manager.py @@ -37,10 +37,10 @@ def test_cluster_applications(self, request_mock): user='root', queue='low', limit=10, started_time_begin=1, started_time_end=2, finished_time_begin=3, finished_time_end=4) - request_mock.assert_called_with('/ws/v1/cluster/apps', params={'state': 'KILLED', - 'finalStatus': 'FAILED', 'user': 'root', 'queue': 'low', - 'limit': 10, 'startedTimeBegin': 1, 'startedTimeEnd': 2, - 'finishedTimeBegin': 3, 'finishedTimeEnd': 4}) + request_mock.assert_called_with('/ws/v1/cluster/apps', params={'state': 'KILLED', 'finalStatus': 'FAILED', + 'user': 'root', 'queue': 'low', 'limit': 10, + 'startedTimeBegin': 1, 'startedTimeEnd': 2, + 'finishedTimeBegin': 3, 'finishedTimeEnd': 4}) with self.assertRaises(IllegalArgumentError): self.rm.cluster_applications(state='ololo') diff --git a/yarn_api_client/__init__.py b/yarn_api_client/__init__.py index f21f683..543b60c 100644 --- a/yarn_api_client/__init__.py +++ b/yarn_api_client/__init__.py @@ -1,5 +1,5 @@ # -*- coding: utf-8 -*- -__version__ = '0.3.6.dev' +__version__ = '0.3.6' __all__ = ['ApplicationMaster', 'HistoryServer', 'NodeManager', 'ResourceManager'] from .application_master import ApplicationMaster