aboutsummaryrefslogtreecommitdiffstats
path: root/components/scripts/python/ccsdk_blueprints/abstract_ra_processor.py
diff options
context:
space:
mode:
Diffstat (limited to 'components/scripts/python/ccsdk_blueprints/abstract_ra_processor.py')
-rw-r--r--components/scripts/python/ccsdk_blueprints/abstract_ra_processor.py43
1 files changed, 40 insertions, 3 deletions
diff --git a/components/scripts/python/ccsdk_blueprints/abstract_ra_processor.py b/components/scripts/python/ccsdk_blueprints/abstract_ra_processor.py
index f7d54ea8..2cacaf52 100644
--- a/components/scripts/python/ccsdk_blueprints/abstract_ra_processor.py
+++ b/components/scripts/python/ccsdk_blueprints/abstract_ra_processor.py
@@ -1,12 +1,49 @@
from org.onap.ccsdk.apps.blueprintsprocessor.functions.resource.resolution.processor import ResourceAssignmentProcessor
+from blueprint_constants import *
+from org.onap.ccsdk.apps.blueprintsprocessor.functions.resource.resolution.utils import ResourceAssignmentUtils
+from org.onap.ccsdk.apps.controllerblueprints.core import BluePrintProcessorException
+from java.lang import Exception
class AbstractRAProcessor(ResourceAssignmentProcessor):
+ def __init__(self):
+ ResourceAssignmentProcessor.__init__(self)
+ self.status = PROPERTY_BLUEPRINT_STATUS_SUCCESS
+ self.error_message = None
+ self.ra_valid = False
+ self.value_to_resolve = None
+
def process(self, execution_request):
- print "Processing calling.."
- return None
+ print "Processing calling from parent..."
+ try:
+ self.ra_valid = self.validate(execution_request)
+ self.value_to_resolve = execution_request.name
+ except Exception, e:
+ self.status = PROPERTY_BLUEPRINT_STATUS_FAILURE
+ self.error_message = "Get Running python scripting Failure :" + e.getMessage()
def recover(self, runtime_exception, execution_request):
- print "Recovering calling.."
+ print "Recovering calling from parent.."
+ return None
+
+ def set_resource_data_value(self, execution_request, value):
+ try:
+ if value is not None:
+ ResourceAssignmentUtils.Companion.setResourceDataValue(execution_request, self.raRuntimeService, value)
+ else:
+ ResourceAssignmentUtils.Companion.setFailedResourceDataValue(execution_request, "Fail to resole value")
+ except BluePrintProcessorException, err:
+ raise BluePrintProcessorException("Error on resource assignment. Message = " + err.message)
+
return None
+
+ @staticmethod
+ def validate(ra):
+ if ra.name is None or ra.name is None:
+ raise Exception("Failed getting value for template key (" + ra.name + ") and " +
+ "dictionary key (" + ra.dictionaryName +
+ ") of type (" + ra.type + ")")
+ else:
+ pass
+ return True