@@ -31,17 +31,16 @@ def test_cluster_scheduler(self, request_mock):
31
31
32
32
def test_cluster_applications (self , request_mock ):
33
33
self .rm .cluster_applications ()
34
- request_mock .assert_called_with ('/ws/v1/cluster/apps' )
34
+ request_mock .assert_called_with ('/ws/v1/cluster/apps' , params = {} )
35
35
36
36
self .rm .cluster_applications (state = 'KILLED' , final_status = 'FAILED' ,
37
37
user = 'root' , queue = 'low' , limit = 10 ,
38
38
started_time_begin = 1 , started_time_end = 2 ,
39
39
finished_time_begin = 3 , finished_time_end = 4 )
40
- request_mock .assert_called_with ('/ws/v1/cluster/apps' , state = 'KILLED' ,
41
- finalStatus = 'FAILED' , user = 'root' ,
42
- queue = 'low' , limit = 10 ,
43
- startedTimeBegin = 1 , startedTimeEnd = 2 ,
44
- finishedTimeBegin = 3 , finishedTimeEnd = 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 })
45
44
46
45
with self .assertRaises (IllegalArgumentError ):
47
46
self .rm .cluster_applications (state = 'ololo' )
@@ -51,7 +50,7 @@ def test_cluster_applications(self, request_mock):
51
50
52
51
def test_cluster_application_statistics (self , request_mock ):
53
52
self .rm .cluster_application_statistics ()
54
- request_mock .assert_called_with ('/ws/v1/cluster/appstatistics' )
53
+ request_mock .assert_called_with ('/ws/v1/cluster/appstatistics' , params = {} )
55
54
# TODO: test arguments
56
55
57
56
def test_cluster_application (self , request_mock ):
0 commit comments