fix(logging): make shutdown queue retry explicit

2026-10-22 08:25:21 +08:00 · 2026-10-18 19:29:36 +08:00
parent 4a989dd8aa
commit de26cebdac
1 changed files with 3 additions and 1 deletions
@@ -136,7 +136,9 @@ class NonBlockingConsoleHandler(logging.Handler):
                        self._queue.get_nowait()
                        self.dropped_records += 1
                    except queue.Empty:
-                        pass
+                        # The writer consumed the last record after Full;
+                        # retry inserting the shutdown sentinel.
+                        continue
        self._worker.join(timeout=CONSOLE_CLOSE_TIMEOUT)