Tachi67 commited on
Commit
659be3c
·
1 Parent(s): 97b6ba2

Update ExtendLibraryFlow.py

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