projects
/
osm
/
MON.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix vROps monitoring problems related to SOL006 migration
[osm/MON.git]
/
osm_mon
/
dashboarder
/
dashboarder.py
diff --git
a/osm_mon/dashboarder/dashboarder.py
b/osm_mon/dashboarder/dashboarder.py
index
30f27d1
..
22aa1bf
100644
(file)
--- a/
osm_mon/dashboarder/dashboarder.py
+++ b/
osm_mon/dashboarder/dashboarder.py
@@
-23,7
+23,6
@@
import logging
import time
import socket
import logging
import time
import socket
-import peewee
import asyncio
from osm_mon.dashboarder.service import DashboarderService
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.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"]
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')))
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")
except Exception:
log.exception("Error creating dashboards")