fix(queue): handle queue.Empty instead of TimeoutError on timeout

InfinityPacer · Sep 24, 2024 · 6d55db4 · 6d55db4
1 parent 8839400
commit 6d55db4
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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}")