From 3814767e28ece9c43c34b978936a66c1e68abe84 Mon Sep 17 00:00:00 2001 From: Jakob Ketterl Date: Wed, 18 Sep 2019 01:46:09 +0200 Subject: [PATCH] count errors --- owrx/wsjt.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/owrx/wsjt.py b/owrx/wsjt.py index 65d077e..531c372 100644 --- a/owrx/wsjt.py +++ b/owrx/wsjt.py @@ -32,6 +32,7 @@ class WsjtQueueWorker(threading.Thread): processor.decode(file) except Exception: logger.exception("failed to decode job") + self.queue.onError() self.queue.task_done() @@ -55,6 +56,8 @@ class WsjtQueue(Queue): metrics.addMetric("wsjt.queue.out", self.outCounter) self.overflowCounter = CounterMetric() metrics.addMetric("wsjt.queue.overflow", self.overflowCounter) + self.errorCounter = CounterMetric() + metrics.addMetric("wsjt.queue.error", self.errorCounter) self.workers = [self.newWorker() for _ in range(0, workers)] def put(self, item): @@ -76,6 +79,9 @@ class WsjtQueue(Queue): worker.start() return worker + def onError(self): + self.errorCounter.inc() + class WsjtChopper(threading.Thread): def __init__(self, source):