changed output of single round
Browse files
ControllerExecutorFlow.py
CHANGED
|
@@ -87,14 +87,14 @@ class ControllerExecutorFlow(CompositeFlow):
|
|
| 87 |
"observation": self.ask_subflow(controller_reply["command"], controller_reply["command_args"]).get_data()
|
| 88 |
}
|
| 89 |
|
| 90 |
-
return executor_reply
|
| 91 |
|
| 92 |
def run(self,input_data):
|
| 93 |
|
| 94 |
executor_reply = input_data
|
| 95 |
|
| 96 |
for round in range(self.flow_config["max_rounds"]):
|
| 97 |
-
executor_reply = self._single_round_controller_executor(executor_reply)
|
| 98 |
|
| 99 |
if executor_reply.get("EARLY_EXIT",False):
|
| 100 |
return executor_reply
|
|
|
|
| 87 |
"observation": self.ask_subflow(controller_reply["command"], controller_reply["command_args"]).get_data()
|
| 88 |
}
|
| 89 |
|
| 90 |
+
return controller_reply, executor_reply
|
| 91 |
|
| 92 |
def run(self,input_data):
|
| 93 |
|
| 94 |
executor_reply = input_data
|
| 95 |
|
| 96 |
for round in range(self.flow_config["max_rounds"]):
|
| 97 |
+
_ , executor_reply = self._single_round_controller_executor(executor_reply)
|
| 98 |
|
| 99 |
if executor_reply.get("EARLY_EXIT",False):
|
| 100 |
return executor_reply
|