X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=policy_module%2Fosm_policy_module%2Fcore%2Fagent.py;h=3a3b20cac9260f6f4b1ccd9badb7369ab90c2471;hb=24b8309395b534ffe4bff9b07f665951555ac955;hp=a38feeb4e262aa2d2ed6e11ff4ea5e741ed52b43;hpb=822fb1930b4abdf834462d0cd26247b0960dcac0;p=osm%2FMON.git diff --git a/policy_module/osm_policy_module/core/agent.py b/policy_module/osm_policy_module/core/agent.py index a38feeb..3a3b20c 100644 --- a/policy_module/osm_policy_module/core/agent.py +++ b/policy_module/osm_policy_module/core/agent.py @@ -25,15 +25,12 @@ import json import logging from typing import Dict, List -import peewee import yaml - from kafka import KafkaConsumer -from osm_policy_module.core.config import Config -from osm_policy_module.common.lcm_client import LcmClient - from osm_policy_module.common.alarm_config import AlarmConfig +from osm_policy_module.common.lcm_client import LcmClient from osm_policy_module.common.mon_client import MonClient +from osm_policy_module.core.config import Config from osm_policy_module.core.database import ScalingRecord, ScalingAlarm log = logging.getLogger(__name__) @@ -116,7 +113,7 @@ class PolicyModuleAgent: log.info("Sending scaling action message for ns: %s", alarm_id) lcm_client.scale(alarm.scaling_record.nsr_id, alarm.scaling_record.name, alarm.action) except ScalingAlarm.DoesNotExist: - log.info("There is no action configured for alarm %.", alarm_id) + log.info("There is no action configured for alarm %s.", alarm_id) except Exception: log.exception("Error consuming message: ")