This commit is contained in:
jxxghp
2025-01-08 12:28:53 +08:00
parent 9446e88012
commit 293d89510a
+3 -4
View File
@@ -495,11 +495,10 @@ class TransferChain(ChainBase, metaclass=Singleton):
return True, "" return True, ""
def put_to_queue(self, task: TransferTask, callback: Optional[Callable] = None): def put_to_queue(self, task: TransferTask):
""" """
添加到待整理队列 添加到待整理队列
:param task: 任务信息 :param task: 任务信息
:param callback: 回调函数
""" """
if not task: if not task:
return return
@@ -508,7 +507,7 @@ class TransferChain(ChainBase, metaclass=Singleton):
# 添加到队列 # 添加到队列
self._queue.put(TransferQueue( self._queue.put(TransferQueue(
task=task, task=task,
callback=callback or self.__default_callback callback=self.__default_callback
)) ))
def __put_to_jobview(self, task: TransferTask): def __put_to_jobview(self, task: TransferTask):
@@ -612,7 +611,7 @@ class TransferChain(ChainBase, metaclass=Singleton):
""" """
try: try:
# 维护整理任务视图 # 维护整理任务视图
if task.background: if not task.background:
self.__put_to_jobview(task) self.__put_to_jobview(task)
# 识别 # 识别
if not task.mediainfo: if not task.mediainfo: