Merge pull request #27925 from tchaikov/wip-38628

mgr/restful: do not use filter() for list

Reviewed-by: Volker Theile <vtheile@suse.com>
Reviewed-by: Boris Ranto <branto@redhat.com>
This commit is contained in:
Kefu Chai 2019-05-09 15:11:15 +08:00 committed by GitHub
commit e714a33b3f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 13 additions and 24 deletions

View File

@ -16,15 +16,11 @@ class MonName(RestController):
"""
Show the information for the monitor name
"""
mon = filter(
lambda x: x['name'] == self.name,
context.instance.get_mons()
)
mon = [x for x in context.instance.get_mons()
if x['name'] == self.name]
if len(mon) != 1:
response.status = 500
return {'message': 'Failed to identify the monitor node "{}"'.format(self.name)}
return mon[0]

View File

@ -16,17 +16,12 @@ class RequestId(RestController):
"""
Show the information for the request id
"""
request = filter(
lambda x: x.id == self.request_id,
context.instance.requests
)
request = [x for x in context.instance.requests
if x.id == self.request_id]
if len(request) != 1:
response.status = 500
return {'message': 'Unknown request id "{}"'.format(self.request_id)}
request = request[0]
return request
return request[0]
@expose(template='json')
@ -66,15 +61,13 @@ class Request(RestController):
"""
num_requests = len(context.instance.requests)
context.instance.requests = filter(
lambda x: not x.is_finished(),
context.instance.requests
)
context.instance.requests = [x for x in context.instance.requests
if not x.is_finished()]
remaining = len(context.instance.requests)
# Return the job statistics
return {
'cleaned': num_requests - len(context.instance.requests),
'remaining': len(context.instance.requests),
'cleaned': num_requests - remaining,
'remaining': remaining,
}

View File

@ -79,16 +79,16 @@ class CommandsRequest(object):
# Gather the results (in parallel)
results = []
for index in range(len(commands)):
for index, command in enumerate(commands):
tag = '%s:%s:%d' % (__name__, self.id, index)
# Store the result
result = CommandResult(tag)
result.command = common.humanify_command(commands[index])
result.command = common.humanify_command(command)
results.append(result)
# Run the command
context.instance.send_command(result, 'mon', '', json.dumps(commands[index]), tag)
context.instance.send_command(result, 'mon', '', json.dumps(command), tag)
return results