Fixed checking already in queue item message.
This commit is contained in:
parent
4838750cf5
commit
85957f1c8c
1 changed files with 9 additions and 4 deletions
|
|
@ -113,10 +113,15 @@ class DownloadQueue:
|
||||||
|
|
||||||
await self.clear([item.info._id])
|
await self.clear([item.info._id])
|
||||||
|
|
||||||
if self.queue.exists(key=entry.get('id'), url=entry.get('webpage_url') or entry.get('url')):
|
try:
|
||||||
log.info(
|
item = self.queue.get(key=entry.get('id'), url=entry.get(
|
||||||
f'Item [{item.info.title}] already in download queue')
|
'webpage_url') or entry.get('url'))
|
||||||
return {'status': 'error', 'msg': 'Link already queued for downloading.'}
|
if item is not None:
|
||||||
|
log.info(
|
||||||
|
f'Item [{item.info.title}] already in download queue.')
|
||||||
|
return {'status': 'error', 'msg': 'Link already queued for downloading.'}
|
||||||
|
except KeyError:
|
||||||
|
pass
|
||||||
|
|
||||||
dl = ItemDTO(
|
dl = ItemDTO(
|
||||||
id=entry.get('id'),
|
id=entry.get('id'),
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue