fix queue error

hamlsy · hamlsy · commit 3103f26c85d8 · 2025-12-31T17:06:43.000+09:00
diff --git a/EchoShotX-ai-private b/EchoShotX-ai-private
@@ -1 +1 @@
-Subproject commit f30aa80c260f00dac368aabce3834cfc0aeda548
+Subproject commit 03386fa398e376dfc0dfb4bb47843e34089d6e38
diff --git a/echoshot_ai_server/services/worker_pool.py b/echoshot_ai_server/services/worker_pool.py
@@ -1,5 +1,6 @@
 import multiprocessing as mp
 from multiprocessing import Process, Queue
+from queue import Empty
 from typing import List
 import signal
 import time
@@ -107,7 +108,7 @@ def _worker_loop(self, worker_id: int) -> None:
                         self.sqs_client.delete_message(job.receipt_handle)
                         logger.error(f"Job {job.job_id} exceeded max retries")
 
-            except Queue.Empty:
+            except Empty:
                 continue
             except Exception as e:
                 logger.error(f"Worker {worker_id} error: {e}", exc_info=True)
