X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_nbi%2Fnbi.py;h=fed3205137440e70dc08733bda0c3f4104e8d756;hb=ea3a2c2766d6d6c652c758b8b5c3a90b004f157a;hp=fa414f053384983fa4b1c786697f9f1bd27c8846;hpb=f2af4a100d308e07f355d61b94fb27d1ccc97aa2;p=osm%2FNBI.git diff --git a/osm_nbi/nbi.py b/osm_nbi/nbi.py index fa414f05..fed32051 100644 --- a/osm_nbi/nbi.py +++ b/osm_nbi/nbi.py @@ -32,6 +32,7 @@ from osm_nbi.validation import ValidationError from osm_common.dbbase import DbException from osm_common.fsbase import FsException from osm_common.msgbase import MsgException +from osm_common.wftemporal import WFTemporal from http import HTTPStatus from codecs import getreader from os import environ, path @@ -904,7 +905,7 @@ class Server(object): project_name=None, ns_id=None, *args, - **kwargs + **kwargs, ): if topic == "alarms": try: @@ -1385,7 +1386,7 @@ class Server(object): _id=None, item=None, *args, - **kwargs + **kwargs, ): token_info = None outdata = None @@ -1854,7 +1855,7 @@ def _start_service(): update_dict["server.socket_host"] = v elif k1 in ("server", "test", "auth", "log"): update_dict[k1 + "." + k2] = v - elif k1 in ("message", "database", "storage", "authentication"): + elif k1 in ("message", "database", "storage", "authentication", "temporal"): # k2 = k2.replace('_', '.') if k2 in ("port", "db_port"): engine_config[k1][k2] = int(v) @@ -1940,6 +1941,10 @@ def _start_service(): subscription_thread.start() # Do not capture except SubscriptionException + WFTemporal.temporal_api = ( + f'{engine_config["temporal"]["host"]}:{engine_config["temporal"]["port"]}' + ) + backend = engine_config["authentication"]["backend"] cherrypy.log.error( "Starting OSM NBI Version '{} {}' with '{}' authentication backend".format(