revert
Project: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/commit/69052330 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/tree/69052330 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/diff/69052330 Branch: refs/heads/ARIA-160-Operation-toolbelt-unit-tests-fail-spordically Commit: 690523304235be6377d6845d3052c47cb8cbda81 Parents: 7b48ec5 Author: max-orlov <[email protected]> Authored: Thu May 4 18:47:18 2017 +0300 Committer: max-orlov <[email protected]> Committed: Thu May 4 18:47:18 2017 +0300 ---------------------------------------------------------------------- aria/orchestrator/workflows/core/task.py | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/blob/69052330/aria/orchestrator/workflows/core/task.py ---------------------------------------------------------------------- diff --git a/aria/orchestrator/workflows/core/task.py b/aria/orchestrator/workflows/core/task.py index 4f86306..4abe865 100644 --- a/aria/orchestrator/workflows/core/task.py +++ b/aria/orchestrator/workflows/core/task.py @@ -176,10 +176,9 @@ class OperationTask(BaseTask): self._update_fields = {} try: yield - task = self.model_task for key, value in self._update_fields.items(): - setattr(task, key, value) - self.model_task = task + setattr(self.model_task, key, value) + self.model_task = self.model_task finally: self._update_fields = None @@ -189,15 +188,11 @@ class OperationTask(BaseTask): Returns the task model in storage :return: task in storage """ - if self._model_task is None: - self._model_task = self._workflow_context.model.task.get(self._task_id) - return self._model_task + return self._workflow_context.model.task.get(self._task_id) @model_task.setter def model_task(self, value): - self._model_task = None self._workflow_context.model.task.put(value) - self._workflow_context.model.task.refresh(value) @property def context(self):
