instance: handle Domain not found exception fixes #32
Showing
... | @@ -671,8 +671,13 @@ class Instance(AclBase, VirtualMachineDescModel, TimeStampedModel): | ... | @@ -671,8 +671,13 @@ class Instance(AclBase, VirtualMachineDescModel, TimeStampedModel): |
# Destroy virtual machine | # Destroy virtual machine | ||
with act.sub_activity('destroying_vm'): | with act.sub_activity('destroying_vm'): | ||
queue_name = self.get_remote_queue_name('vm') | queue_name = self.get_remote_queue_name('vm') | ||
vm_tasks.destroy.apply_async(args=[self.vm_name], | try: | ||
queue=queue_name).get() | vm_tasks.destroy.apply_async(args=[self.vm_name], | ||
queue=queue_name).get() | |||
except Exception as e: | |||
if e.libvirtError is True: | |||
if "Domain not found" in str(e): | |||
pass | |||
Please
register
or
sign in
to reply
|
|||
def __cleanup_after_destroy_vm(self, act): | def __cleanup_after_destroy_vm(self, act): | ||
"""Clean up the virtual machine's data after destroy. | """Clean up the virtual machine's data after destroy. | ||
... | ... |