Update ExtendLibraryFlow.py
Browse files- ExtendLibraryFlow.py +15 -1
ExtendLibraryFlow.py
CHANGED
@@ -1,4 +1,18 @@
|
|
1 |
from flow_modules.Tachi67.AbstractBossFlowModule import AbstractBossFlow
|
2 |
|
3 |
class ExtendLibraryFlow(AbstractBossFlow):
|
4 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
1 |
from flow_modules.Tachi67.AbstractBossFlowModule import AbstractBossFlow
|
2 |
|
3 |
class ExtendLibraryFlow(AbstractBossFlow):
|
4 |
+
def run(self, input_data: Dict[str, Any]) -> Dict[str, Any]:
|
5 |
+
# ~~~ sets the input_data in the flow_state dict ~~~
|
6 |
+
self._state_update_dict(update_data=input_data)
|
7 |
+
|
8 |
+
max_rounds = self.flow_config.get("max_rounds", 1)
|
9 |
+
if max_rounds is None:
|
10 |
+
log.info(f"Running {self.flow_config['name']} without `max_rounds` until the early exit condition is met.")
|
11 |
+
|
12 |
+
self._sequential_run(max_rounds=max_rounds)
|
13 |
+
|
14 |
+
output = self._get_output_from_state()
|
15 |
+
|
16 |
+
self.reset(full_reset=True, recursive=True, src_flow=self)
|
17 |
+
|
18 |
+
return output
|