X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fdashboarder%2Fdashboarder.py;h=a6ff5bca2cbb49897dc59ece775dbb23f67a2510;hb=2fe71f21fe75ee283d39e66391d7d3a094713569;hp=30f27d1ba8ca49ef6bed293dbbe64db9a0f7661f;hpb=85a9185db3248f1e3f20c8edad95ab77b8ee989c;p=osm%2FMON.git

diff --git a/osm_mon/dashboarder/dashboarder.py b/osm_mon/dashboarder/dashboarder.py
index 30f27d1..a6ff5bc 100644
--- a/osm_mon/dashboarder/dashboarder.py
+++ b/osm_mon/dashboarder/dashboarder.py
@@ -1,6 +1,6 @@
 # -*- coding: utf-8 -*-
 
-# Copyright 2018 Whitestack, LLC
+# Copyright 2021 Whitestack, LLC
 # *************************************************************
 
 # This file is part of OSM Monitoring module
@@ -18,12 +18,12 @@
 # License for the specific language governing permissions and limitations
 # under the License.
 # For those usages not covered by the Apache License, Version 2.0 please
-# contact: bdiaz@whitestack.com or glavado@whitestack.com
+# contact: fbravo@whitestack.com or glavado@whitestack.com
 ##
+
 import logging
 import time
 import socket
-import peewee
 import asyncio
 
 from osm_mon.dashboarder.service import DashboarderService
@@ -61,7 +61,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,12 +95,9 @@ 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")
 
     def create_dashboards(self):
         self.service.create_dashboards()
-        log.debug('I just called the dashboarder service!')
+        log.debug('Dashboarder Service > create_dashboards called!')