from manager.mancelery import celery @celery.task def deploy(disk, user): disk.deploy(task_uuid=deploy.request.id, user=user) @celery.task def destroy(disk, user): disk.destroy(task_uuid=destroy.request.id, user=user) @celery.task def restore(disk, user): disk.restore(task_uuid=restore.request.id, user=user)