From 6d55db466c433eb4d83f02c128fc2ef22d0e869b Mon Sep 17 00:00:00 2001 From: InfinityPacer <160988576+InfinityPacer@users.noreply.github.com> Date: Wed, 25 Sep 2024 00:46:55 +0800 Subject: [PATCH] fix(queue): handle queue.Empty instead of TimeoutError on timeout --- app/monitor.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/app/monitor.py b/app/monitor.py index c02b0ac7d..e70d15ec7 100644 --- a/app/monitor.py +++ b/app/monitor.py @@ -1,4 +1,5 @@ import platform +import queue import re import threading import traceback @@ -242,7 +243,7 @@ def __start_transfer(self): self.__handle_file(storage=item.get("storage"), event_path=item.get("filepath"), mon_path=item.get("mon_path")) - except TimeoutError: + except queue.Empty: continue except Exception as e: logger.error(f"整理队列处理出现错误:{e}")