Co-authored-by: 刘江波 <jiangbo721@163.com>tags/1.1.0
| def create_copy(self): | def create_copy(self): | ||||
| """ | """ | ||||
| create a graph engine copy | create a graph engine copy | ||||
| :return: with a new variable pool instance of graph engine | |||||
| :return: graph engine with a new variable pool and initialized total tokens | |||||
| """ | """ | ||||
| new_instance = copy(self) | new_instance = copy(self) | ||||
| new_instance.graph_runtime_state = copy(self.graph_runtime_state) | new_instance.graph_runtime_state = copy(self.graph_runtime_state) | ||||
| new_instance.graph_runtime_state.variable_pool = deepcopy(self.graph_runtime_state.variable_pool) | new_instance.graph_runtime_state.variable_pool = deepcopy(self.graph_runtime_state.variable_pool) | ||||
| new_instance.graph_runtime_state.total_tokens = 0 | |||||
| return new_instance | return new_instance | ||||
| def _handle_continue_on_error( | def _handle_continue_on_error( |
| with flask_app.app_context(): | with flask_app.app_context(): | ||||
| parallel_mode_run_id = uuid.uuid4().hex | parallel_mode_run_id = uuid.uuid4().hex | ||||
| graph_engine_copy = graph_engine.create_copy() | graph_engine_copy = graph_engine.create_copy() | ||||
| graph_engine_copy.graph_runtime_state.total_tokens = 0 | |||||
| variable_pool_copy = graph_engine_copy.graph_runtime_state.variable_pool | variable_pool_copy = graph_engine_copy.graph_runtime_state.variable_pool | ||||
| variable_pool_copy.add([self.node_id, "index"], index) | variable_pool_copy.add([self.node_id, "index"], index) | ||||
| variable_pool_copy.add([self.node_id, "item"], item) | variable_pool_copy.add([self.node_id, "item"], item) |