X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=installers%2Fcharm%2Fnbi%2Fsrc%2Fcharm.py;h=848b53d9fd803c97a1c8b1a2347ecce5b8be0b9d;hb=426d4938f27b200f359078258f41109b399d5e06;hp=7ef9d59eb260c90cf1eefc22ead59bff68763b3f;hpb=9b6ad36b93538bbe2621b8c30d899862d8840e60;p=osm%2Fdevops.git diff --git a/installers/charm/nbi/src/charm.py b/installers/charm/nbi/src/charm.py index 7ef9d59e..848b53d9 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 @@ -32,7 +31,7 @@ from oci_image import OCIImageResource, OCIImageResourceError from pod_spec import make_pod_spec -LOGGER = logging.getLogger(__name__) +logger = logging.getLogger(__name__) NBI_PORT = 9999 @@ -142,7 +141,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: @@ -214,7 +213,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 @@ -255,7 +254,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: @@ -274,13 +273,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. @@ -366,8 +364,8 @@ class NbiCharm(CharmBase): self.model.app.name, self.port, ) - except ValidationError as exc: - LOGGER.exception("Config/Relation data validation error") + except ValueError as exc: + logger.exception("Config/Relation data validation error") self.unit.status = BlockedStatus(str(exc)) return