vm: return AsyncResult of async methods

circle/vm/models.py

@@ -571,7 +571,7 @@ class Instance(BaseResourceConfigModel, TimeStampedModel):
     def deploy_async(self, user=None):
         """Execute deploy asynchronously.
         """
-        local_tasks.deploy.apply_async(args=[self, user],
+        return local_tasks.deploy.apply_async(args=[self, user],
                                               queue="localhost.man")
 
     def destroy(self, user=None, task_uuid=None):
@@ -617,7 +617,7 @@ class Instance(BaseResourceConfigModel, TimeStampedModel):
     def destroy_async(self, user=None):
         """Execute destroy asynchronously.
         """
-        local_tasks.destroy.apply_async(args=[self, user],
+        return local_tasks.destroy.apply_async(args=[self, user],
                                                queue="localhost.man")
 
     def sleep(self, user=None, task_uuid=None):
@@ -639,7 +639,8 @@ class Instance(BaseResourceConfigModel, TimeStampedModel):
     def sleep_async(self, user=None):
         """Execute sleep asynchronously.
         """
-        local_tasks.sleep.apply_async(args=[self, user], queue="localhost.man")
+        return local_tasks.sleep.apply_async(args=[self, user],
+                                             queue="localhost.man")
 
     def wake_up(self, user=None, task_uuid=None):
         act = InstanceActivity(activity_code='vm.Instance.wake_up')
@@ -658,7 +659,7 @@ class Instance(BaseResourceConfigModel, TimeStampedModel):
     def wake_up_async(self, user=None):
         """Execute wake_up asynchronously.
         """
-        local_tasks.wake_up.apply_async(args=[self, user],
+        return local_tasks.wake_up.apply_async(args=[self, user],
                                                queue="localhost.man")
 
     def shutdown(self, user=None, task_uuid=None):
@@ -680,7 +681,7 @@ class Instance(BaseResourceConfigModel, TimeStampedModel):
     def shutdown_async(self, user=None):
         """Execute shutdown asynchronously.
         """
-        local_tasks.shutdown.apply_async(args=[self, user],
+        return local_tasks.shutdown.apply_async(args=[self, user],
                                                 queue="localhost.man")
 
     def reset(self, user=None, task_uuid=None):
@@ -702,7 +703,7 @@ class Instance(BaseResourceConfigModel, TimeStampedModel):
     def reset_async(self, user=None):
         """Execute reset asynchronously.
         """
-        local_tasks.restart.apply_async(args=[self, user],
+        return local_tasks.restart.apply_async(args=[self, user],
                                                queue="localhost.man")
 
     def reboot(self, user=None, task_uuid=None):
@@ -724,10 +725,9 @@ class Instance(BaseResourceConfigModel, TimeStampedModel):
     def reboot_async(self, user=None):
         """Execute reboot asynchronously.
         """
-        local_tasks.reboot.apply_async(args=[self, user],
+        return local_tasks.reboot.apply_async(args=[self, user],
                                               queue="localhost.man")
 
-
 class InstanceActivity(TimeStampedModel):
     activity_code = CharField(verbose_name=_('activity_code'), max_length=100)
     task_uuid = CharField(verbose_name=_('task_uuid'), blank=True,