X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fcollector%2Fcollector.py;h=a69e651a6c3a4bc0af382dacb055c96a1c7a9179;hb=072b0bdeb1a0919c5cc8de128fa3c62e8393ed7c;hp=cc844364e91d749d2b2901fa3d3c0c0bbdb78b51;hpb=a97bdb3eafa4f3d07d61d32635f7f36f5cc36c58;p=osm%2FMON.git

diff --git a/osm_mon/collector/collector.py b/osm_mon/collector/collector.py
index cc84436..a69e651 100644
--- a/osm_mon/collector/collector.py
+++ b/osm_mon/collector/collector.py
@@ -23,17 +23,13 @@
 import logging
 import time
 
-import peewee
-
 from osm_mon.collector.backends.prometheus import PrometheusBackend
 from osm_mon.collector.service import CollectorService
 from osm_mon.core.config import Config
 
 log = logging.getLogger(__name__)
 
-METRIC_BACKENDS = [
-    PrometheusBackend
-]
+METRIC_BACKENDS = [PrometheusBackend]
 
 
 class Collector:
@@ -44,14 +40,11 @@ class Collector:
         self._init_backends()
 
     def collect_forever(self):
-        log.debug('collect_forever')
+        log.debug("collect_forever")
         while True:
             try:
                 self.collect_metrics()
-                time.sleep(int(self.conf.get('collector', 'interval')))
-            except peewee.PeeweeException:
-                log.exception("Database error consuming message: ")
-                raise
+                time.sleep(int(self.conf.get("collector", "interval")))
             except Exception:
                 log.exception("Error collecting metrics")