X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=policy_module%2Fosm_policy_module%2Fcommon%2Flcm_client.py;h=be44efe361eb381909cfe2905de870bb2220119d;hb=d9a55971b0b87f0d43883f840478f6fbc5f62fde;hp=75e40c3aab8835ab3c94fffd7b43f63b715a71f9;hpb=034a5305e1535971979b842e4ee73bee40d8b1af;p=osm%2FMON.git diff --git a/policy_module/osm_policy_module/common/lcm_client.py b/policy_module/osm_policy_module/common/lcm_client.py index 75e40c3..be44efe 100644 --- a/policy_module/osm_policy_module/common/lcm_client.py +++ b/policy_module/osm_policy_module/common/lcm_client.py @@ -40,13 +40,13 @@ class LcmClient: key_serializer=str.encode, value_serializer=str.encode) - def scale(self, nsr_id, name, action): + def scale(self, nsr_id: str, name: str, action: str): msg = self._create_scale_action_payload(nsr_id, name, action) log.info("Sending scale action message: %s", json.dumps(msg)) self.producer.send(topic='lcm_pm', key='trigger_scaling', value=json.dumps(msg)) self.producer.flush() - def _create_scale_action_payload(self, nsr_id, name, action): + def _create_scale_action_payload(self, nsr_id: str, name: str, action: str): msg = { "ns_id": nsr_id, "scaling_group_descriptor": {