X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=installers%2Fcharm%2Fnbi%2Fsrc%2Fcharm.py;h=f2b2ecf77da1be3a1b28273b03a50cb930e3b2ba;hb=ed4306b661ba5e949a8fc2b5ff216ae13c799741;hp=3970a33d6a639d191425daa7e6755e0dca3afb73;hpb=4df5a461573ae47200e893453c7c7d9cb89da30d;p=osm%2Fdevops.git diff --git a/installers/charm/nbi/src/charm.py b/installers/charm/nbi/src/charm.py index 3970a33d..f2b2ecf7 100755 --- a/installers/charm/nbi/src/charm.py +++ b/installers/charm/nbi/src/charm.py @@ -22,7 +22,6 @@ import logging from typing import Any, Dict, NoReturn -from pydantic import ValidationError from ops.charm import CharmBase, CharmEvents from ops.framework import EventBase, EventSource, StoredState @@ -144,7 +143,7 @@ class NbiCharm(CharmBase): ) ): self.state.message_host = message_host - self.state.message_port = message_port + self.state.message_port = int(message_port) self.on.configure_pod.emit() def _on_kafka_relation_departed(self, event: EventBase) -> NoReturn: @@ -220,7 +219,7 @@ class NbiCharm(CharmBase): ) ): self.state.keystone_host = keystone_host - self.state.keystone_port = keystone_port + self.state.keystone_port = int(keystone_port) self.state.keystone_user_domain_name = keystone_user_domain_name self.state.keystone_project_domain_name = keystone_project_domain_name self.state.keystone_username = keystone_username @@ -263,7 +262,7 @@ class NbiCharm(CharmBase): ) ): self.state.prometheus_host = prometheus_host - self.state.prometheus_port = prometheus_port + self.state.prometheus_port = int(prometheus_port) self.on.configure_pod.emit() def _on_prometheus_relation_departed(self, event: EventBase) -> NoReturn: @@ -282,13 +281,12 @@ class NbiCharm(CharmBase): Args: event (EventBase): NBI relation event. """ - if self.unit.is_leader(): - rel_data = { - "host": self.model.app.name, - "port": str(NBI_PORT), - } - for k, v in rel_data.items(): - event.relation.data[self.model.app][k] = v + rel_data = { + "host": self.model.app.name, + "port": str(NBI_PORT), + } + for k, v in rel_data.items(): + event.relation.data[self.unit][k] = v def _missing_relations(self) -> str: """Checks if there missing relations. @@ -374,7 +372,7 @@ class NbiCharm(CharmBase): self.model.app.name, self.port, ) - except ValidationError as exc: + except ValueError as exc: logger.exception("Config/Relation data validation error") self.unit.status = BlockedStatus(str(exc)) return