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__)
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__)
- 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")))