strix

commit 89ccd188ffceb24a590b410f3d14a2b598f49d15
parent 6986bb73bb604c8b44eee8d2cbd2818a2299ee88
Author: Brian C. Lane <bcl@brianlane.com>
Date:   Sun, 23 Jun 2019 14:04:17 -0700

Add missing queue.task_done() call to log handler

Diffstat:
M
src/strix/logger.py
 | 
2
+-

1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/strix/logger.py b/src/strix/logger.py
@@ -14,7 +14,6 @@
 #
 # You should have received a copy of the GNU General Public License
 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
-import sys
 import logging
 from logging.handlers import RotatingFileHandler, QueueHandler
 import multiprocessing as mp
@@ -54,6 +53,7 @@ def listener(queue: mp.Queue, stop_event: mp.Event, log_path: str) -> None:
             if record is None: # We send this as a sentinel to tell the listener to quit.
                 break
             logger.handle(record) # No level or filter logic applied - just do it!
+            queue.task_done()
         except (KeyboardInterrupt, SystemExit):
             raise
         except: