X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fcmd%2Fmon_evaluator.py;h=cc36d9900ca9965f23d30ed6613dc59fdeea82e9;hb=b170aec221ad296cc9de06a7b6069c878211cc65;hp=3835d7e966d576bbc2db43668be5a39e3035eaa0;hpb=5ac7c081ca13495185ecf6bdf302c16c25a4b759;p=osm%2FMON.git diff --git a/osm_mon/cmd/mon_evaluator.py b/osm_mon/cmd/mon_evaluator.py index 3835d7e..cc36d99 100644 --- a/osm_mon/cmd/mon_evaluator.py +++ b/osm_mon/cmd/mon_evaluator.py @@ -26,13 +26,13 @@ import logging import sys from osm_mon.core.config import Config -from osm_mon.core.database import DatabaseManager from osm_mon.evaluator.evaluator import Evaluator +from osm_mon.cmd.mon_utils import wait_till_core_services_are_ready def main(): - parser = argparse.ArgumentParser(prog='osm-policy-agent') - parser.add_argument('--config-file', nargs='?', help='POL configuration file') + parser = argparse.ArgumentParser(prog='osm-mon-evaluator') + parser.add_argument('--config-file', nargs='?', help='MON configuration file') args = parser.parse_args() cfg = Config(args.config_file) @@ -45,14 +45,18 @@ def main(): root.addHandler(ch) log = logging.getLogger(__name__) - log.info("Starting MON Evaluator...") - log.debug("Config: %s", cfg.conf) - log.info("Initializing database...") - db_manager = DatabaseManager(cfg) - db_manager.create_tables() - log.info("Database initialized correctly.") - evaluator = Evaluator(cfg) - evaluator.evaluate_forever() + if wait_till_core_services_are_ready(cfg, "osm-mon-evaluator"): + log.info("Starting MON Evaluator...") + log.debug("Config: %s", cfg.conf) + log.info("Initializing database...") + try: + evaluator = Evaluator(cfg) + evaluator.evaluate_forever() + except Exception as e: + log.error("Failed to start MON Evaluator") + log.debug("Exception: %s", str(e)) + else: + log.error("Failed to start MON Evaluator") if __name__ == '__main__':