Upload 3 files

AbstractBossFlow.py

@@ -0,0 +1,57 @@
+from copy import deepcopy
+from typing import Dict, Any
+
+from flows.base_flows import SequentialFlow
+from flows.utils import logging
+from abc import ABC
+
+
+logging.set_verbosity_debug()
+log = logging.get_logger(__name__)
+
+class AbstractBossFlow(SequentialFlow, ABC):
+    """
+    Abstract class of a 'boss': e.g. coder, ExtLib
+    """
+    REQUIRED_KEYS_CONFIG = ["max_rounds", "early_exit_key", "topology", "memory_files"]
+
+    def __init__(
+            self,
+            memory_files: Dict[str, Any],
+            **kwargs
+    ):
+        super().__init__(**kwargs)
+        self.memory_files = memory_files
+
+    @classmethod
+    def instantiate_from_config(cls, config):
+        flow_config = deepcopy(config)
+
+        kwargs = {"flow_config": flow_config}
+
+        # ~~~ Set up memory file ~~~
+        memory_files = flow_config["memory_files"]
+        kwargs.update({"memory_files": memory_files})
+
+        # ~~~ Set up subflows ~~~
+        kwargs.update({"subflows": cls._set_up_subflows(flow_config)})
+
+        # ~~~ Instantiate flow ~~~
+        return cls(**kwargs)
+
+    def run(self, input_data: Dict[str, Any]) -> Dict[str, Any]:
+        # ~~~ sets the input_data in the flow_state dict ~~~
+        self._state_update_dict(update_data=input_data)
+
+        # ~~~ set the memory file to the flow state ~~~
+        self._state_update_dict(update_data={"memory_files": self.memory_files})
+
+        max_rounds = self.flow_config.get("max_rounds", 1)
+        if max_rounds is None:
+            log.info(f"Running {self.flow_config['name']} without `max_rounds` until the early exit condition is met.")
+
+        self._sequential_run(max_rounds=max_rounds)
+
+        output = self._get_output_from_state()
+
+        return output

AbstractBossFlow.yaml

@@ -0,0 +1,51 @@
+name: "AbstractBossFlow"
+description: "Abstract class of a boss, e.g. coder, ExtendLibrary, etc."
+
+_target_: Tachi67.AbstractBossFlowModule.AbstractBossFlow.instantiate_from_default_config
+
+memory_files: ???
+
+input_interface:
+  - "goal"
+
+output_interface:
+  - "answer"
+  - "summary" # to be written into the logs of the upper level boss
+
+subflows_config:
+  MemoryReading:
+    _target_: Tachi67.MemoryReadingFlowModule.MemoryReadingAtomicFlow.instantiate_from_default_config
+
+  Planner:
+    _target_: Tachi67.PlanWriterFlowModule.PlanWriterFlow.instantiate_from_default_config
+
+  # the flow with a controller, few executors in a branch, memory reading and memory writing
+  CtrlExMem:
+    _target_: Tachi67.CtrlExMemFlowModule.CtrlExMemFlow.instantiate_from_default_config
+
+early_exit_key: "EARLY_EXIT"
+
+topology:
+  - goal: "Read in necessary memory"
+    input_interface:
+      _target_: flows.interfaces.KeyInterface
+      additional_transformations:
+        - _target_: flows.data_transformations.KeyMatchInput
+    flow: MemoryReading
+    reset: false
+
+  - goal: "Make plans in an interactive fashion, write the plan into the plan file"
+    input_interface:
+      _target_: flows.interfaces.KeyInterface
+      additional_transformations:
+        - _target_: flows.data_transformations.KeyMatchInput
+    flow: Planner
+    reset: false
+
+  - goal: "Execute the plan and return answer & a summary of what was done"
+    input_interface:
+      _target_: flows.interfaces.KeyInterface
+      additional_transformations:
+        - _target_: flows.data_transformations.KeyMatchInput
+    flow: CtrlExMem
+    reset: false

__init__.py

@@ -0,0 +1,9 @@
+dependencies = [
+    {"url": "Tachi67/MemoryReadingFlowModule", "revision": "main"},
+    {"url": "Tachi67/PlanWriterFlowModule", "revision":"main"},
+    {"url": "Tachi67/CtrlExMemFlowModule", "revision":"main"},
+]
+from flows import flow_verse
+
+flow_verse.sync_dependencies(dependencies)
+from .AbstractBossFlow import AbstractBossFlow