We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2a4ec01 commit 17ee702Copy full SHA for 17ee702
README.rst
@@ -88,6 +88,10 @@ Programmatic interface
88
Changelog
89
=========
90
91
+0.3.6 Release
92
+ - Extend ResourceManager to allow applications to better
93
+ determine resource availability prior to submission.
94
+
95
0.3.5 Release
96
- Hotfix release to fix internal signature mismatch
97
tests/test_hadoop_conf.py
@@ -165,7 +165,6 @@ def test_get_jobhistory_host_port(self):
165
host_port = hadoop_conf.get_jobhistory_host_port()
166
self.assertIsNone(host_port)
167
168
-
169
def test_get_nodemanager_host_port(self):
170
with patch('yarn_api_client.hadoop_conf.parse') as parse_mock:
171
parse_mock.return_value = 'example.com:8022'
@@ -182,7 +181,6 @@ def test_get_nodemanager_host_port(self):
182
181
host_port = hadoop_conf.get_nodemanager_host_port()
183
184
185
186
def test_get_webproxy_host_port(self):
187
188
tests/test_node_manager.py
@@ -18,7 +18,7 @@ def test_node_information(self, request_mock):
18
def test_node_applications(self, request_mock):
19
self.nm.node_applications('RUNNING', 'root')
20
request_mock.assert_called_with('/ws/v1/node/apps',
21
- params={"state":'RUNNING', "user":'root'})
+ params={"state": 'RUNNING', "user": 'root'})
22
23
self.nm.node_applications()
24
request_mock.assert_called_with('/ws/v1/node/apps', params={})
tests/test_resource_manager.py
@@ -37,10 +37,10 @@ def test_cluster_applications(self, request_mock):
37
user='root', queue='low', limit=10,
38
started_time_begin=1, started_time_end=2,
39
finished_time_begin=3, finished_time_end=4)
40
- request_mock.assert_called_with('/ws/v1/cluster/apps', params={'state': 'KILLED',
41
- 'finalStatus': 'FAILED', 'user': 'root', 'queue': 'low',
42
- 'limit': 10, 'startedTimeBegin': 1, 'startedTimeEnd': 2,
43
- '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})
44
45
with self.assertRaises(IllegalArgumentError):
46
self.rm.cluster_applications(state='ololo')
yarn_api_client/__init__.py
@@ -1,5 +1,5 @@
1
# -*- coding: utf-8 -*-
2
-__version__ = '0.3.6.dev'
+__version__ = '0.3.6'
3
__all__ = ['ApplicationMaster', 'HistoryServer', 'NodeManager', 'ResourceManager']
4
5
from .application_master import ApplicationMaster
0 commit comments