MON changes for Grafana Multitenancy feature.

[osm/MON.git] / osm_mon / cmd / mon_dashboarder.py

diff --git a/osm_mon/cmd/mon_dashboarder.py b/osm_mon/cmd/mon_dashboarder.py
index 211038d..b49b570 100644 (file)
--- a/osm_mon/cmd/mon_dashboarder.py
+++ b/osm_mon/cmd/mon_dashboarder.py
@@ -27,6 +27,7 @@ import sys
 
 from osm_mon.core.config import Config
 from osm_mon.dashboarder.dashboarder import Dashboarder
+import threading
 
 
 def main():
@@ -47,6 +48,9 @@ def main():
     log.info("Starting MON Dashboarder...")
     log.debug("Config: %s", cfg.conf)
     dashboarder = Dashboarder(cfg)
+    log.info("Starting MON kafka Consumer...")
+    threading.Thread(target=dashboarder.run, args=()).start()
+    log.info("Starting MON Dashboarder...")
     dashboarder.dashboard_forever()