X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fdashboarder%2Fdashboarder.py;h=22aa1bfb26657c0a6f9095813ba609292a97725c;hb=09bcf03e83c5863c3c0bcf47a457e70162fca94e;hp=30f27d1ba8ca49ef6bed293dbbe64db9a0f7661f;hpb=85a9185db3248f1e3f20c8edad95ab77b8ee989c;p=osm%2FMON.git diff --git a/osm_mon/dashboarder/dashboarder.py b/osm_mon/dashboarder/dashboarder.py index 30f27d1..22aa1bf 100644 --- a/osm_mon/dashboarder/dashboarder.py +++ b/osm_mon/dashboarder/dashboarder.py @@ -23,7 +23,6 @@ import logging import time import socket -import peewee import asyncio from osm_mon.dashboarder.service import DashboarderService @@ -61,7 +60,6 @@ class Dashboarder: log.debug("Received message from kafka for deleting user") user = values['username'] self.service.delete_grafana_user(user) - log.info("Grafana user deleted: %s", user) elif topic == "users" and key == "edited": log.debug("Received message from kafka for associating user to team") user_id = values["_id"] @@ -96,9 +94,6 @@ class Dashboarder: try: self.create_dashboards() time.sleep(int(self.conf.get('dashboarder', 'interval'))) - except peewee.PeeweeException: - log.exception("Database error consuming message: ") - raise except Exception: log.exception("Error creating dashboards")