valid_flags = set(args.keys()) & set(common.OSD_FLAGS)
invalid_flags = list(set(args.keys()) - valid_flags)
if invalid_flags:
- context.instance.log.warn("%s not valid to set/unset" % invalid_flags)
+ context.instance.log.warn("%s not valid to set/unset", invalid_flags)
for flag in list(valid_flags):
if args[flag]:
if not osd:
response.status = 500
- return {'message': 'Failed to identify the OSD id "%d"' % self.osd_id}
+ return {'message': 'Failed to identify the OSD id "{}"'.format(self.osd_id)}
if osd['up']:
return common.OSD_IMPLEMENTED_COMMANDS
if not osd:
response.status = 500
- return {'message': 'Failed to identify the OSD id "%d"' % self.osd_id}
+ return {'message': 'Failed to identify the OSD id "{}"'.format(self.osd_id)}
if not osd['up'] or command not in common.OSD_IMPLEMENTED_COMMANDS:
response.status = 500
- return {'message': 'Command "%s" not available' % command}
+ return {'message': 'Command "{}" not available'.format(command)}
return context.instance.submit_request([[{
'prefix': 'osd ' + command,
osd = context.instance.get_osds(ids=[str(self.osd_id)])
if len(osd) != 1:
response.status = 500
- return {'message': 'Failed to identify the OSD id "%d"' % self.osd_id}
+ return {'message': 'Failed to identify the OSD id "{}"'.format(self.osd_id)}
return osd[0]
if not pool:
response.status = 500
- return {'message': 'Failed to identify the pool id "%d"' % self.pool_id}
+ return {'message': 'Failed to identify the pool id "{}"'.format(self.pool_id)}
# pgp_num is called pg_placement_num, deal with that
if 'pg_placement_num' in pool:
pool = context.instance.get_pool_by_id(self.pool_id)
if not pool:
response.status = 500
- return {'message': 'Failed to identify the pool id "%d"' % self.pool_id}
+ return {'message': 'Failed to identify the pool id "{}"'.format(self.pool_id)}
# Check for invalid pool args
invalid = common.invalid_pool_args(args)
if invalid:
response.status = 500
- return {'message': 'Invalid arguments found: "%s"' % str(invalid)}
+ return {'message': 'Invalid arguments found: "{}"'.format(invalid)}
# Schedule the update request
return context.instance.submit_request(common.pool_update_commands(pool['pool_name'], args), **kwargs)
if not pool:
response.status = 500
- return {'message': 'Failed to identify the pool id "%d"' % self.pool_id}
+ return {'message': 'Failed to identify the pool id "{}"'.format(self.pool_id)}
return context.instance.submit_request([[{
'prefix': 'osd pool delete',
invalid = common.invalid_pool_args(args)
if invalid:
response.status = 500
- return {'message': 'Invalid arguments found: "%s"' % str(invalid)}
+ return {'message': 'Invalid arguments found: "{}"'.format(invalid)}
# Schedule the creation and update requests
return context.instance.submit_request(