This commit is contained in:
ArabCoders 2023-11-28 18:05:14 +03:00
parent bd9cf01b91
commit 6e05c78664

View file

@ -98,7 +98,7 @@ class DownloadQueue:
if self.done.exists(key=entry['id'], url=entry.get('webpage_url') or entry['url']): if self.done.exists(key=entry['id'], url=entry.get('webpage_url') or entry['url']):
item = self.done.get(key=entry['id'], url=entry.get( item = self.done.get(key=entry['id'], url=entry.get(
'webpage_url') or entry['url']) 'webpage_url') or entry['url'])
self.done.clear([item.info._id]) self.clear([item.info._id])
if self.queue.exists(key=entry['id'], url=entry.get('webpage_url') or entry['url']): if self.queue.exists(key=entry['id'], url=entry.get('webpage_url') or entry['url']):
return {'status': 'error', 'msg': 'Link already queued for downloading.'} return {'status': 'error', 'msg': 'Link already queued for downloading.'}
@ -230,7 +230,7 @@ class DownloadQueue:
async def clear(self, ids): async def clear(self, ids):
for id in ids: for id in ids:
if not self.done.exists(id): if not self.done.exists(key=id):
log.warn(f'requested delete for non-existent download {id}') log.warn(f'requested delete for non-existent download {id}')
continue continue
self.done.delete(id) self.done.delete(id)