openstack
/
nova
Code Issues Proposed changes

Merge "Remove return from rpc cast"

This commit is contained in:
Zuul 2022-07-10 12:06:25 +00:00 committed by Gerrit Code Review
parent 90c0c687a4 7824471b79
commit 4bead404fe
3 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nova/compute/rpcapi.py
View File

@ -1503,7 +1503,7 @@ class ComputeAPI(object):
client = self.router.client(ctxt) client = self.router.client(ctxt)
cctxt = client.prepare(server=_compute_host(None, instance), cctxt = client.prepare(server=_compute_host(None, instance),
version=version) version=version)
return cctxt.cast(ctxt, "trigger_crash_dump", instance=instance) cctxt.cast(ctxt, "trigger_crash_dump", instance=instance)
def cache_images(self, ctxt, host, image_ids): def cache_images(self, ctxt, host, image_ids):
version = self._ver(ctxt, '5.4') version = self._ver(ctxt, '5.4')

2
nova/conductor/rpcapi.py
View File

@ -473,4 +473,4 @@ class ComputeTaskAPI(object):
raise exception.ServiceTooOld(_('nova-conductor too old')) raise exception.ServiceTooOld(_('nova-conductor too old'))
kw = {'instance': instance, 'migration': migration} kw = {'instance': instance, 'migration': migration}
cctxt = self.client.prepare(version=version) cctxt = self.client.prepare(version=version)
return cctxt.cast(ctxt, 'revert_snapshot_based_resize', **kw) cctxt.cast(ctxt, 'revert_snapshot_based_resize', **kw)

12
nova/scheduler/rpcapi.py
View File

@ -171,15 +171,15 @@ class SchedulerAPI(object):
def update_instance_info(self, ctxt, host_name, instance_info): def update_instance_info(self, ctxt, host_name, instance_info):
cctxt = self.client.prepare(version='4.2', fanout=True) cctxt = self.client.prepare(version='4.2', fanout=True)
return cctxt.cast(ctxt, 'update_instance_info', host_name=host_name, cctxt.cast(ctxt, 'update_instance_info', host_name=host_name,
instance_info=instance_info) instance_info=instance_info)
def delete_instance_info(self, ctxt, host_name, instance_uuid): def delete_instance_info(self, ctxt, host_name, instance_uuid):
cctxt = self.client.prepare(version='4.2', fanout=True) cctxt = self.client.prepare(version='4.2', fanout=True)
return cctxt.cast(ctxt, 'delete_instance_info', host_name=host_name, cctxt.cast(ctxt, 'delete_instance_info', host_name=host_name,
instance_uuid=instance_uuid) instance_uuid=instance_uuid)
def sync_instance_info(self, ctxt, host_name, instance_uuids): def sync_instance_info(self, ctxt, host_name, instance_uuids):
cctxt = self.client.prepare(version='4.2', fanout=True) cctxt = self.client.prepare(version='4.2', fanout=True)
return cctxt.cast(ctxt, 'sync_instance_info', host_name=host_name, cctxt.cast(ctxt, 'sync_instance_info', host_name=host_name,
instance_uuids=instance_uuids) instance_uuids=instance_uuids)