From 45689830774688c455873f03f2bdd3a7be4685ce Mon Sep 17 00:00:00 2001 From: guzzijones Date: Wed, 12 Jul 2023 01:17:17 +0000 Subject: [PATCH] revert stage deepcopy removal --- orquesta/conducting.py | 2 +- orquesta/tests/unit/base.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/orquesta/conducting.py b/orquesta/conducting.py index 21b9b3c9..9189970d 100644 --- a/orquesta/conducting.py +++ b/orquesta/conducting.py @@ -52,7 +52,7 @@ def serialize(self): "contexts": self.contexts, "routes": self.routes, "sequence": self.sequence, - "staged": self.staged, + "staged": json_util.deepcopy(self.staged), "status": self.status, "tasks": self.tasks, } diff --git a/orquesta/tests/unit/base.py b/orquesta/tests/unit/base.py index 94197486..d0cca988 100644 --- a/orquesta/tests/unit/base.py +++ b/orquesta/tests/unit/base.py @@ -217,7 +217,7 @@ def assert_task_list(self, conductor, actual, expected): for task in expected_copy: task["ctx"]["__current_task"] = {"id": task["id"], "route": task["route"]} - task["ctx"]["__state"] = copy.deepcopy(conductor.workflow_state.serialize()) + task["ctx"]["__state"] = conductor.workflow_state.serialize() for staged_task in task["ctx"]["__state"]["staged"]: if "items" in staged_task: