Commit 50555ea6 by Guba Sándor Committed by Őry Máté

storage: fixed disk download

parent f0c7a301
...@@ -350,10 +350,12 @@ class Disk(AclBase, TimeStampedModel): ...@@ -350,10 +350,12 @@ class Disk(AclBase, TimeStampedModel):
:rtype: Disk :rtype: Disk
""" """
params.setdefault('name', url.split('/')[-1]) params.setdefault('name', url.split('/')[-1])
disk = cls.__create(type="iso", user=user, size=None, **params) params.setdefault('type', 'iso')
params.setdefault('size', None)
disk = cls.__create(params=params, user=user)
queue_name = disk.get_remote_queue_name('storage', priority='slow') queue_name = disk.get_remote_queue_name('storage', priority='slow')
remote = storage_tasks.download.apply_async( remote = storage_tasks.download.apply_async(
kwargs={'url': url, 'parent_id': task.id, kwargs={'url': url, 'parent_id': task.request.id,
'disk': disk.get_disk_desc()}, 'disk': disk.get_disk_desc()},
queue=queue_name) queue=queue_name)
while True: while True:
......
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