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/288e0632 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/tree/288e0632 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/diff/288e0632 Branch: refs/heads/ARIA-126-update-node-statuses Commit: 288e06323f28ac1d47baea87ea3b957121e06f86 Parents: 3e42a8e Author: Avia Efrat <[email protected]> Authored: Sun Mar 26 12:21:41 2017 +0300 Committer: Avia Efrat <[email protected]> Committed: Sun Mar 26 12:25:33 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/288e0632/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
