import asyncio
import logging
import sys
+import os
from osm_policy_module.core.agent import PolicyModuleAgent
from osm_policy_module.core.config import Config
def main():
+ # Cleanup old temp health file
+ if os.path.exists('/tmp/osm_pol_agent_health_flag'):
+ os.remove('/tmp/osm_pol_agent_health_flag')
+
parser = argparse.ArgumentParser(prog='osm-policy-agent')
parser.add_argument('--config-file', nargs='?', help='POL configuration file')
args = parser.parse_args()
log = logging.getLogger(__name__)
log.debug("Config: %s", cfg.conf)
log.info("Initializing database...")
- db_manager = DatabaseManager()
- db_manager.init_db(cfg)
+ db_manager = DatabaseManager(cfg)
+ db_manager.create_tables()
log.info("Database initialized correctly.")
log.info("Starting policy module agent...")
loop = asyncio.get_event_loop()