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

Merge pull request #5406 from cddjr/fix_transfer

Browse Source
This commit is contained in:
jxxghp
2026-01-24 06:45:10 +08:00
committed by GitHub
parent f1e26a4133 1532014067
commit 474f47aa9f
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/chain/transfer.py
+4 -4
View File
@@ -660,9 +660,6 @@ class TransferChain(ChainBase, ConfigReloadMixin, metaclass=Singleton):
# 删除剩余空目录 # 删除剩余空目录
StorageChain().delete_media_file(t.fileitem, delete_self=False) StorageChain().delete_media_file(t.fileitem, delete_self=False)
# 清理作业
self.jobview.remove_job(task)
return ret_status, ret_message return ret_status, ret_message
def put_to_queue(self, task: TransferTask): def put_to_queue(self, task: TransferTask):
@@ -971,11 +968,14 @@ class TransferChain(ChainBase, ConfigReloadMixin, metaclass=Singleton):
# 从下载器获取种子列表 # 从下载器获取种子列表
if torrents_list := self.list_torrents(status=TorrentStatus.TRANSFER): if torrents_list := self.list_torrents(status=TorrentStatus.TRANSFER):
seen = set()
existing_hashes = self.jobview.get_all_torrent_hashes() existing_hashes = self.jobview.get_all_torrent_hashes()
torrents = [ torrents = [
torrent torrent
for torrent in torrents_list for torrent in torrents_list
if torrent.hash not in existing_hashes if (h := torrent.hash) not in existing_hashes
# 排除多下载器返回的重复种子
and (h not in seen and (seen.add(h) or True))
] ]
else: else:
torrents = [] torrents = []