Adds projects_read and projects_write params to scaling nslcmop

[osm/POL.git] / osm_policy_module / autoscaling / service.py

diff --git a/osm_policy_module/autoscaling/service.py b/osm_policy_module/autoscaling/service.py
index 09b78b2..8bb17e4 100644 (file)
--- a/osm_policy_module/autoscaling/service.py
+++ b/osm_policy_module/autoscaling/service.py
@@ -51,6 +51,11 @@ class AutoscalingService:
         self.lcm_client = LcmClient(config, loop=self.loop)
 
     async def configure_scaling_groups(self, nsr_id: str):
+        """
+        Configures scaling groups for a network service. Creates records in DB. Creates alarms in MON.
+        :param nsr_id: Network service record id
+        :return:
+        """
         log.info("Configuring scaling groups for network service with nsr_id: %s",
                  nsr_id)
         alarms_created = []
@@ -71,7 +76,7 @@ class AutoscalingService:
                             try:
                                 scaling_group_record = ScalingGroupRepository.get(
                                     ScalingGroup.nsr_id == nsr_id,
-                                    ScalingGroup.vnf_member_index == int(vnfr['member-vnf-index-ref']),
+                                    ScalingGroup.vnf_member_index == vnfr['member-vnf-index-ref'],
                                     ScalingGroup.name == scaling_group['name']
                                 )
                                 log.debug("Found existing scaling group record in DB...")
@@ -203,7 +208,7 @@ class AutoscalingService:
                                         alarm = ScalingAlarmRepository.create(
                                             alarm_uuid=alarm_uuid,
                                             action='scale_in',
-                                            vnf_member_index=int(vnfr['member-vnf-index-ref']),
+                                            vnf_member_index=vnfr['member-vnf-index-ref'],
                                             vdu_name=vdur['name'],
                                             scaling_criteria=scaling_criteria_record
                                         )
@@ -220,7 +225,7 @@ class AutoscalingService:
                                         alarm = ScalingAlarmRepository.create(
                                             alarm_uuid=alarm_uuid,
                                             action='scale_out',
-                                            vnf_member_index=int(vnfr['member-vnf-index-ref']),
+                                            vnf_member_index=vnfr['member-vnf-index-ref'],
                                             vdu_name=vdur['name'],
                                             scaling_criteria=scaling_criteria_record
                                         )