Upload utils.py

utils.py

@@ -70,31 +70,54 @@ def format_bytes(size):
     return f"{size:.4f}{power_labels[n]+'B'}"
 
 
-LOGGER_QUEUE = queue.Queue(5)
+LOGGER_QUEUE = queue.Queue(int(os.environ.get('LOGGER_QUEUE_SIZE', 100)))
 
 
 def logger():
+    """Background thread to post logs to LOG_PORT. Uses blocking get so the thread
+    will wait for items and won't spin when queue empty. Any errors are swallowed
+    to avoid crashing the logger thread.
+    """
     print("enable")
     while True:
-        item = LOGGER_QUEUE.get()
+        try:
+            item = LOGGER_QUEUE.get()
+        except Exception:
+            # If queue is unexpectedly closed or an error occurs, keep running
+            time.sleep(0.1)
+            continue
         try:
             LOG_PORT = os.environ.get("LOG_PORT")
             if LOG_PORT:
+                # Best-effort; ignore any network error
                 requests.post(
                     LOG_PORT,
                     headers={"Content-Type": "application/json"},
                     json=item,
+                    timeout=5,
                 )
         except Exception:
+            # never let log failures escape to the main thread
             pass
 
 
 if os.environ.get("LOG_PORT"):
-    threading.Thread(target=logger).start()
+    # make the logger thread a daemon so it won't block process exit
+    t = threading.Thread(target=logger, daemon=True)
+    t.start()
 
 
 def log(item):
-    LOGGER_QUEUE.put_nowait(item)
+    try:
+        LOGGER_QUEUE.put_nowait(item)
+    except queue.Full:
+        # Queue is full: drop the log (best-effort). Avoid raising to keep the
+        # application responsive; optionally print a fallback log to console
+        try:
+            # Use a short, non-blocking print so at least something is recorded
+            print("LOG DROP: queue full, dropping log item")
+        except Exception:
+            pass
 
 
 def web_search(query: str, top_k: int = 3) -> str: