Move cluster, KSU, profile and OKA operation initialization logic to LCM
Change-Id: I57cef96c6e8c99b7278ee9969580e28f40d0c8a7
Signed-off-by: garciadeblas <gerardo.garciadeblas@telefonica.com>
diff --git a/osm_nbi/base_topic.py b/osm_nbi/base_topic.py
index 7fbb815..b4ee7bd 100644
--- a/osm_nbi/base_topic.py
+++ b/osm_nbi/base_topic.py
@@ -411,14 +411,8 @@
return None
@staticmethod
- def format_on_operation(
- content, operation_type, operation_params=None, launch_workflow=True
- ):
- if content["current_operation"] is None:
- op_id = str(uuid4())
- content["current_operation"] = op_id
- else:
- op_id = content["current_operation"]
+ def format_on_operation(content, operation_type, operation_params=None):
+ op_id = str(uuid4())
now = time()
if "operationHistory" not in content:
content["operationHistory"] = []
@@ -429,16 +423,10 @@
operation["result"] = None
operation["creationDate"] = now
operation["endDate"] = None
- if launch_workflow:
- operation["workflowState"] = "PROCESSING"
- operation["resourceState"] = "NOT_READY"
- operation["operationState"] = "IN_PROGRESS"
- operation["gitOperationInfo"] = None
- operation["operationParams"] = operation_params
- else:
- operation["workflowState"] = operation["resourceState"] = operation[
- "operationState"
- ] = operation["gitOperationInfo"] = operation["operationParams"] = None
+ operation["workflowState"] = operation["resourceState"] = operation[
+ "operationState"
+ ] = operation["gitOperationInfo"] = None
+ operation["operationParams"] = operation_params
content["operationHistory"].append(operation)
return op_id