Skip to content

Commit 5b9650d

Browse files
author
Sergio García Prado
committed
* Now port is not a mandatory field in config.
1 parent 8315624 commit 5b9650d

File tree

2 files changed

+9
-4
lines changed

2 files changed

+9
-4
lines changed

packages/core/minos-microservice-common/minos/common/config/v2.py

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -115,14 +115,16 @@ def _get_interfaces(self) -> dict[str, dict[str, Any]]:
115115

116116
@staticmethod
117117
def _parse_http_interface(data: dict[str, Any]) -> dict[str, Any]:
118-
data["port"] = import_module(data["port"])
118+
if "port" in data:
119+
data["port"] = import_module(data["port"])
119120
if "connector" in data:
120121
data["connector"]["client"] = import_module(data["connector"]["client"])
121122
return data
122123

123124
@staticmethod
124125
def _parse_broker_interface(data: dict[str, Any]) -> dict[str, Any]:
125-
data["port"] = import_module(data["port"])
126+
if "port" in data:
127+
data["port"] = import_module(data["port"])
126128

127129
if "publisher" in data:
128130
data["publisher"]["client"] = import_module(data["publisher"]["client"])
@@ -140,7 +142,8 @@ def _parse_broker_interface(data: dict[str, Any]) -> dict[str, Any]:
140142

141143
@staticmethod
142144
def _parse_periodic_interface(data: dict[str, Any]) -> dict[str, Any]:
143-
data["port"] = import_module(data["port"])
145+
if "port" in data:
146+
data["port"] = import_module(data["port"])
144147

145148
return data
146149

packages/core/minos-microservice-common/minos/common/launchers.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,9 @@ def _from_config(cls, *args, config: Config, **kwargs) -> EntrypointLauncher:
107107
if "injections" not in kwargs:
108108
kwargs["injections"] = config.get_injections()
109109
if "ports" not in kwargs:
110-
kwargs["ports"] = [interface["port"] for interface in config.get_interfaces().values()]
110+
kwargs["ports"] = [
111+
interface["port"] for interface in config.get_interfaces().values() if "port" in interface
112+
]
111113
return cls(config, *args, **kwargs)
112114

113115
def launch(self) -> NoReturn:

0 commit comments

Comments
 (0)