vm: sync local tasks with model changes

circle/vm/models.py

@@ -626,8 +626,8 @@ class Instance(BaseResourceConfigModel, TimeStampedModel):
     def wake_up_async(self, user=None):
     def wake_up_async(self, user=None):
         """Execute wake_up asynchronously.
         """Execute wake_up asynchronously.
         """
         """
-        local_tasks.resume.apply_async(args=[self, user],
-                                       queue="localhost.man")
+        local_tasks.wake_up.apply_async(args=[self, user],
+                                        queue="localhost.man")
 
 
     def shutdown(self, user=None, task_uuid=None):
     def shutdown(self, user=None, task_uuid=None):
         """Shutdown virtual machine with ACPI signal.
         """Shutdown virtual machine with ACPI signal.

circle/vm/tasks/local_tasks.py

 from manager.mancelery import celery
 from manager.mancelery import celery
 
 
-# TODO: Keep syncronhised with Instance funcs
+# TODO: Keep synchronised with Instance funcs
+
 
 
 @celery.task
 @celery.task
 def deploy(instance, user):
 def deploy(instance, user):
-    ''' Call Insance.deploy() from celery task.
-    '''
     instance.deploy(task_uuid=deploy.request.id, user=user)
     instance.deploy(task_uuid=deploy.request.id, user=user)
 
 
 
 
-def destroy():
-    pass
+@celery.task
+def destroy(instance, user):
+    instance.destroy(task_uuid=destroy.request.id, user=user)
 
 
 
 
-def save_as():
-    pass
+@celery.task
+def sleep(instance, user):
+    instance.sleep(task_uuid=sleep.request.id, user=user)
 
 
 
 
-def suspend():
-    pass
+@celery.task
+def wake_up(instance, user):
+    instance.wake_up(task_uuid=wake_up.request.id, user=user)
 
 
 
 
-def resume():
-    pass
+@celery.task
+def shutdown(instance, user):
+    instance.shutdown(task_uuid=shutdown.request.id, user=user)
 
 
 
 
-def restart():
-    pass
+@celery.task
+def reset(instance, user):
+    instance.reset(task_uuid=reset.request.id, user=user)
 
 
 
 
-def reset():
-    pass
+@celery.task
+def reboot(instance, user):
+    instance.reboot(task_uuid=reboot.request.id, user=user)
+
 
 
+@celery.task
+def save_as(instance, user):
+    instance.save_as(task_uuid=save_as.request.id, user=user)
 
 
-def migrate():
-    pass
+
+@celery.task
+def migrate(instance, user):
+    instance.migrate(task_uuid=migrate.request.id, user=user)