commit 2bed607156fddac61713016080ab65f8d0050900
author Mark Beierl <mark.beierl@canonical.com> Wed Apr 05 20:01:41 2023 +0000
committer Mark Beierl <mark.beierl@canonical.com> Thu Apr 06 01:35:15 2023 +0000
tree b20cb6ad6bf0a16cc2b275217dfa81dfed7a8576
parent 02a39fd2739a929d803d0268dbf86da8ffb77642

NS LCM OP Workflow wrapper

Change-Id: I21ad95463237d5b3f65a7cca58d1dbe5031e2b4a
Signed-off-by: Mark Beierl <mark.beierl@canonical.com>

osm_lcm/nglcm.py

diff --git a/osm_lcm/nglcm.py b/osm_lcm/nglcm.py
index 6c6f196..0e8811b 100644
--- a/osm_lcm/nglcm.py
+++ b/osm_lcm/nglcm.py
@@ -20,6 +20,7 @@
 import getopt
 import logging
 import logging.handlers
+import os
 import sys
 import yaml
 
@@ -29,6 +30,8 @@
 from osm_lcm.data_utils.lcm_config import LcmCfg
 from osm_lcm.lcm_utils import LcmException
 from os import path
+from osm_lcm.temporal.lcm_activities import NsLcmActivity
+from osm_lcm.temporal.lcm_workflows import NsNoOpWorkflow
 from osm_lcm.temporal.vim_activities import VimDbActivity, JujuPaasConnector
 from osm_lcm.temporal.vim_workflows import (
     VimCreateWorkflow,
@@ -126,20 +129,32 @@
         client = await Client.connect(temporal_api)
         data_activity_instance = VimDbActivity(self.db)
         paas_connector_instance = JujuPaasConnector(self.db)
+        nslcm_activity_instance = NsLcmActivity(self.db)
 
-        workflows = [VimCreateWorkflow, VimDeleteWorkflow, VimUpdateWorkflow]
+        workflows = [
+            NsNoOpWorkflow,
+            VimCreateWorkflow,
+            VimDeleteWorkflow,
+            VimUpdateWorkflow,
+        ]
         activities = [
             data_activity_instance.update_vim_operation_state,
             data_activity_instance.update_vim_state,
             data_activity_instance.delete_vim_record,
+            nslcm_activity_instance.update_ns_lcm_operation_state,
+            nslcm_activity_instance.no_op,
             paas_connector_instance.test_vim_connectivity,
         ]
 
+        # Check if we are running under a debugger
+        debug = os.getenv("VSCODE_IPC_HOOK_CLI") is not None
+
         worker = Worker(
             client,
             task_queue=LCM_TASK_QUEUE,
             workflows=workflows,
             activities=activities,
+            debug_mode=debug,
         )
 
         self.logger.info("Starting LCM temporal worker")