Commit bc56f9c1 by Dudás Ádám

storage: return job handle in async methods

parent 29065d2d
...@@ -197,8 +197,8 @@ class Disk(TimeStampedModel): ...@@ -197,8 +197,8 @@ class Disk(TimeStampedModel):
def deploy_async(self, user=None): def deploy_async(self, user=None):
"""Execute deploy asynchronously. """Execute deploy asynchronously.
""" """
local_tasks.deploy.apply_async(args=[self, user], return local_tasks.deploy.apply_async(args=[self, user],
queue="localhost.man") queue="localhost.man")
def destroy(self, user=None, task_uuid=None): def destroy(self, user=None, task_uuid=None):
if self.destroyed: if self.destroyed:
...@@ -211,8 +211,8 @@ class Disk(TimeStampedModel): ...@@ -211,8 +211,8 @@ class Disk(TimeStampedModel):
return True return True
def destroy_async(self, user=None): def destroy_async(self, user=None):
local_tasks.destroy.apply_async(args=[self, user], return local_tasks.destroy.apply_async(args=[self, user],
queue='localhost.man') queue='localhost.man')
def restore(self, user=None, task_uuid=None): def restore(self, user=None, task_uuid=None):
"""Restore destroyed disk. """Restore destroyed disk.
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment