And condition for updating the node states
Project: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/commit/c3abcc87 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/tree/c3abcc87 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/diff/c3abcc87 Branch: refs/heads/ARIA-126-update-node-statuses Commit: c3abcc87074c7a0a6c7ddecb66a0c47e65d884bb Parents: 44ac15f Author: Avia Efrat <[email protected]> Authored: Sun Mar 26 12:21:41 2017 +0300 Committer: Avia Efrat <[email protected]> Committed: Sun Mar 26 12:21:41 2017 +0300 ---------------------------------------------------------------------- aria/orchestrator/workflows/core/events_handler.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/blob/c3abcc87/aria/orchestrator/workflows/core/events_handler.py ---------------------------------------------------------------------- diff --git a/aria/orchestrator/workflows/core/events_handler.py b/aria/orchestrator/workflows/core/events_handler.py index 7191674..80d1266 100644 --- a/aria/orchestrator/workflows/core/events_handler.py +++ b/aria/orchestrator/workflows/core/events_handler.py @@ -27,8 +27,12 @@ from datetime import ( timedelta, ) +from aria.orchestrator.workflows.core.task import OperationTask + from ... import events from ... import exceptions +from ... context.operation import NodeOperationContext + @events.sent_task_signal.connect def _task_sent(task, *args, **kwargs): @@ -43,7 +47,8 @@ def _task_started(task, *args, **kwargs): task.status = task.STARTED # update node state if necessary - _update_node_state(task, transitional=True) + if type(task) is OperationTask and type(task.context) is NodeOperationContext: + _update_node_state(task, transitional=True) @events.on_failure_task_signal.connect @@ -78,7 +83,8 @@ def _task_succeeded(task, *args, **kwargs): task.status = task.SUCCESS # update node state if necessary - _update_node_state(task) + if type(task) is OperationTask and type(task.context) is NodeOperationContext: + _update_node_state(task) @events.start_workflow_signal.connect
