NS LCM OP Workflow wrapper

[osm/NBI.git] / osm_nbi / nbi.py

diff --git a/osm_nbi/nbi.py b/osm_nbi/nbi.py
index fa414f0..fed3205 100644 (file)
--- 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(