From ea4fdfd6e236ea4928310bb74671f787e199d7c3 Mon Sep 17 00:00:00 2001 From: hanshuaikang <1758504262@qq.com> Date: Mon, 20 Nov 2023 16:39:33 +0800 Subject: [PATCH] =?UTF-8?q?bugfix:=20=E4=BF=AE=E5=A4=8D=E5=BF=AB=E7=85=A7?= =?UTF-8?q?=E5=9B=9E=E6=BB=9A=E6=97=B6=E5=8F=8D=E5=BA=8F=E5=88=97=E5=8C=96?= =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- runtime/bamboo-pipeline/pipeline/contrib/rollback/tasks.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/runtime/bamboo-pipeline/pipeline/contrib/rollback/tasks.py b/runtime/bamboo-pipeline/pipeline/contrib/rollback/tasks.py index cabd7c4..259df0c 100644 --- a/runtime/bamboo-pipeline/pipeline/contrib/rollback/tasks.py +++ b/runtime/bamboo-pipeline/pipeline/contrib/rollback/tasks.py @@ -100,8 +100,8 @@ def execute_rollback(self): node_snapshots = RollbackNodeSnapshot.objects.filter(node_id=self.node_id, rolled_back=False).order_by("-id") for node_snapshot in node_snapshots: service = self.runtime.get_service(code=node_snapshot.code, version=node_snapshot.version) - data = ExecutionData(inputs=json.loads(node_snapshot.inputs), outputs=json.loads(node_snapshot.outputs)) - parent_data = ExecutionData(inputs=json.loads(node_snapshot.context_values), outputs={}) + data = ExecutionData(inputs=node_snapshot.inputs, outputs=node_snapshot.outputs) + parent_data = ExecutionData(inputs=node_snapshot.context_values, outputs={}) result = service.service.rollback(data, parent_data, self.retry_data) node_snapshot.rolled_back = True node_snapshot.save()