GithubBackup/MoviePilot
1
0
Fork 0
mirror of https://github.com/jxxghp/MoviePilot.git synced 2026-09-05 15:38:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix 整理队列锁

Browse Source
This commit is contained in:
jxxghp
2024-12-30 19:02:16 +08:00
parent 54c98cf3a1
commit c0ad5f2970
1 changed files with 17 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/chain/transfer.py
+17 -17
View File
@@ -444,22 +444,21 @@ class TransferChain(ChainBase, metaclass=Singleton):
'download_hash': task.download_hash, 'download_hash': task.download_hash,
}) })
# 全部整理成功时
if self.jobview.is_success(task):
# 移动模式删除空目录
if transferinfo.transfer_type in ["move"]:
# 所有成功的业务
tasks = self.jobview.success_tasks(task.mediainfo, task.meta.begin_season)
for t in tasks:
# 下载器hash
if t.download_hash:
if self.remove_torrents(t.download_hash, downloader=t.downloader):
logger.info(f"移动模式删除种子成功：{t.download_hash} ")
# 删除残留目录
if t.fileitem:
self.storagechain.delete_media_file(t.fileitem, delete_self=False)
with task_lock: with task_lock:
# 全部整理成功时
if self.jobview.is_success(task):
# 移动模式删除空目录
if transferinfo.transfer_type in ["move"]:
# 所有成功的业务
tasks = self.jobview.success_tasks(task.mediainfo, task.meta.begin_season)
for t in tasks:
# 下载器hash
if t.download_hash:
if self.remove_torrents(t.download_hash, downloader=t.downloader):
logger.info(f"移动模式删除种子成功：{t.download_hash} ")
# 删除残留目录
if t.fileitem:
self.storagechain.delete_media_file(t.fileitem, delete_self=False)
# 整理完成且有成功的任务时 # 整理完成且有成功的任务时
if self.jobview.is_finished(task): if self.jobview.is_finished(task):
# 发送通知 # 发送通知
@@ -577,8 +576,9 @@ class TransferChain(ChainBase, metaclass=Singleton):
text=__process_msg, text=__process_msg,
key=ProgressKey.FileTransfer) key=ProgressKey.FileTransfer)
# 移除已完成的任务 # 移除已完成的任务
if self.jobview.is_done(task): with task_lock:
self.jobview.remove_job(task) if self.jobview.is_done(task):
self.jobview.remove_job(task)
except queue.Empty: except queue.Empty:
if not __queue_start: if not __queue_start:
# 结束进度 # 结束进度