From e0b1912b608523881e43e5d7e22610fafba8fac4 Mon Sep 17 00:00:00 2001 From: Miroslav Los Date: Wed, 18 Dec 2019 13:10:24 +0100 Subject: Remove obsolete cdap and docker plugins Signed-off-by: Miroslav Los Issue-ID: DCAEGEN2-1987 Change-Id: I7e7114458a2931b8f1baf915f1714ee8465b86e5 --- docker/dockerplugin/decorators.py | 102 -------------------------------------- 1 file changed, 102 deletions(-) delete mode 100644 docker/dockerplugin/decorators.py (limited to 'docker/dockerplugin/decorators.py') diff --git a/docker/dockerplugin/decorators.py b/docker/dockerplugin/decorators.py deleted file mode 100644 index f83263b..0000000 --- a/docker/dockerplugin/decorators.py +++ /dev/null @@ -1,102 +0,0 @@ -# ============LICENSE_START======================================================= -# org.onap.dcae -# ================================================================================ -# Copyright (c) 2017 AT&T Intellectual Property. All rights reserved. -# ================================================================================ -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. -# ============LICENSE_END========================================================= -# -# ECOMP is a trademark and service mark of AT&T Intellectual Property. - -import copy -from cloudify import ctx -from cloudify.exceptions import NonRecoverableError, RecoverableError -from dockering import utils as doc -from dockerplugin import discovery as dis -from dockerplugin.exceptions import DockerPluginDeploymentError, \ - DockerPluginDependencyNotReadyError -from dockerplugin import utils - - -def monkeypatch_loggers(task_func): - """Sets up the dependent loggers""" - - def wrapper(**kwargs): - # Ouch! Monkeypatch loggers - doc.logger = ctx.logger - dis.logger = ctx.logger - - return task_func(**kwargs) - - return wrapper - - -def wrap_error_handling_start(task_start_func): - """Wrap error handling for the start operations""" - - def wrapper(**kwargs): - try: - return task_start_func(**kwargs) - except DockerPluginDependencyNotReadyError as e: - # You are here because things we need like a working docker host is not - # available yet so let Cloudify try again later. - raise RecoverableError(e) - except DockerPluginDeploymentError as e: - # Container failed to come up in the allotted time. This is deemed - # non-recoverable. - raise NonRecoverableError(e) - except Exception as e: - ctx.logger.error("Unexpected error while starting container: {0}" - .format(str(e))) - raise NonRecoverableError(e) - - return wrapper - - -def _wrapper_merge_inputs(task_func, properties, **kwargs): - """Merge Cloudify properties with input kwargs before calling task func""" - inputs = copy.deepcopy(properties) - # Recursively update - utils.update_dict(inputs, kwargs) - - # Apparently kwargs contains "ctx" which is cloudify.context.CloudifyContext - # This has to be removed and not copied into runtime_properties else you get - # JSON serialization errors. - if "ctx" in inputs: - del inputs["ctx"] - - return task_func(**inputs) - -def merge_inputs_for_create(task_create_func): - """Merge all inputs for start operation into one dict""" - - # Needed to wrap the wrapper because I was seeing issues with - # "RuntimeError: No context set in current execution thread" - def wrapper(**kwargs): - # NOTE: ctx.node.properties is an ImmutableProperties instance which is - # why it is passed into a mutable dict so that it can be deep copied - return _wrapper_merge_inputs(task_create_func, - dict(ctx.node.properties), **kwargs) - - return wrapper - -def merge_inputs_for_start(task_start_func): - """Merge all inputs for start operation into one dict""" - - # Needed to wrap the wrapper because I was seeing issues with - # "RuntimeError: No context set in current execution thread" - def wrapper(**kwargs): - return _wrapper_merge_inputs(task_start_func, - ctx.instance.runtime_properties, **kwargs) - - return wrapper -- cgit 1.2.3-korg