fix check_task.py

oceanbase · May 9, 2024 · 76217f2 · 76217f2
1 parent 09a9779
commit 76217f2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/handler/checker/check_task.py b/handler/checker/check_task.py
@@ -63,15 +63,15 @@ def execute_one_node(self,steps_nu,node):
             self.stdio.verbose("run task in node: {0}".format(StringUtils.node_cut_passwd_for_log(node)))
             steps = self.task[steps_nu]
             nu = 1
+            task_variable_dict={}
             for step in steps["steps"]:
                 try:
                     self.stdio.verbose("step nu: {0}".format(nu))
                     if len(self.cluster) == 0:
                         raise Exception("cluster is not exist")
-                    step_run = StepBase(self.context, step, node, self.cluster, self.task_variable_dict)
+                    step_run = StepBase(self.context, step, node, self.cluster, task_variable_dict)
                     self.stdio.verbose("step nu: {0} initted, to execute".format(nu))
                     step_run.execute(self.report)
-                    self.task_variable_dict=step_run.update_task_variable_dict()
                     if "report_type" in step["result"] and step["result"]["report_type"] == "execution":
                         self.stdio.verbose("report_type stop this step")
                         return

diff --git a/handler/checker/step/stepbase.py b/handler/checker/step/stepbase.py
@@ -33,7 +33,6 @@ def __init__(self, context, step, node, cluster, task_variable_dict):
         self.step = step
         self.node = node
         self.cluster = cluster
-        self.task_variable_dict = {}
         self.task_variable_dict = task_variable_dict
 
     def execute(self, report):