renamed flows to ai flows

AutoGPTFlow.py

@@ -1,8 +1,8 @@
 import sys
 from typing import Dict, Any
 
-from flows.base_flows import CircularFlow
-from flows.utils import logging
+from aiflows.base_flows import CircularFlow
+from aiflows.utils import logging
 
 logging.set_verbosity_debug()
 

AutoGPTFlow.yaml

@@ -13,7 +13,7 @@ output_interface:
 ### Subflows specification
 subflows_config:
   Controller:
-    _target_: aiflows.ControllerExecutorFlowModule.ControllerAtomicFlow.instantiate_from_default_config
+    _target_: flow_modules.aiflows.ControllerExecutorFlowModule.ControllerAtomicFlow.instantiate_from_default_config
     finish:
       description: "Signal that the objective has been satisfied, and returns the answer to the user."
       input_args: ["answer"]
@@ -44,7 +44,7 @@ subflows_config:
       - "memory"
 
   Executor:
-    _target_: flows.base_flows.BranchingFlow.instantiate_from_default_config
+    _target_: aiflows.base_flows.BranchingFlow.instantiate_from_default_config
 # E.g.,
 #    subflows_config:
 #      wiki_search:
@@ -55,7 +55,7 @@ subflows_config:
 #          _target_: langchain.tools.DuckDuckGoSearchRun
 
   HumanFeedback:
-    _target_: aiflows.HumanStandardInputFlowModule.HumanStandardInputFlow.instantiate_from_default_config
+    _target_: flow_modules.aiflows.HumanStandardInputFlowModule.HumanStandardInputFlow.instantiate_from_default_config
     request_multi_line_input_flag: False
     query_message_prompt_template:
       template: |2-
@@ -85,7 +85,7 @@ subflows_config:
       - "observation"
 
   Memory:
-    _target_: aiflows.VectorStoreFlowModule.ChromaDBFlow.instantiate_from_default_config
+    _target_: flow_modules.aiflows.VectorStoreFlowModule.ChromaDBFlow.instantiate_from_default_config
     n_results: 2
 
 topology:
@@ -99,9 +99,9 @@ topology:
 
   - goal: "Select the next action and prepare the input for the executor."
     input_interface:
-      _target_: flows.interfaces.KeyInterface
+      _target_: aiflows.interfaces.KeyInterface
       additional_transformations:
-        - _target_: flows.data_transformations.KeyMatchInput
+        - _target_: aiflows.data_transformations.KeyMatchInput
     flow: Controller
     output_interface:
       _target_: AutoGPTFlow.detect_finish_or_continue # An interface defined as a function in the Flow class
@@ -109,14 +109,14 @@ topology:
 
   - goal: "Execute the action specified by the Controller."
     input_interface:
-      _target_: flows.interfaces.KeyInterface
+      _target_: aiflows.interfaces.KeyInterface
       keys_to_rename:
         command: branch
         command_args: branch_input_data
       keys_to_select: ["branch", "branch_input_data"]
     flow: Executor
     output_interface:
-      _target_: flows.interfaces.KeyInterface
+      _target_: aiflows.interfaces.KeyInterface
       keys_to_rename:
         branch_output_data: observation
       keys_to_select: ["observation"]
@@ -124,7 +124,7 @@ topology:
 
   - goal: "Ask the user for feedback."
     input_interface:
-      _target_: flows.interfaces.KeyInterface
+      _target_: aiflows.interfaces.KeyInterface
     flow: HumanFeedback
     output_interface:
       _target_: AutoGPTFlow.detect_finish_in_human_input

__init__.py

@@ -7,7 +7,7 @@ dependencies = [
     {"url": "aiflows/VectorStoreFlowModule",
      "revision": "main"},
 ]
-from flows import flow_verse
+from aiflows import flow_verse
 
 flow_verse.sync_dependencies(dependencies)
 # ~~~

demo.yaml

@@ -1,11 +1,11 @@
 flow:
-  _target_: aiflows.AutoGPTFlowModule.AutoGPTFlow.instantiate_from_default_config
+  _target_: flow_modules.aiflows.AutoGPTFlowModule.AutoGPTFlow.instantiate_from_default_config
   max_rounds: 30
 
   ### Subflows specification
   subflows_config:
     Controller:
-      _target_: aiflows.ControllerExecutorFlowModule.ControllerAtomicFlow.instantiate_from_default_config
+      _target_: flow_modules.aiflows.ControllerExecutorFlowModule.ControllerAtomicFlow.instantiate_from_default_config
       commands:
         wiki_search:
           description: "Performs a search on Wikipedia."
@@ -29,10 +29,10 @@ flow:
         - "human_feedback"
 
     Executor:
-      _target_: flows.base_flows.BranchingFlow.instantiate_from_default_config
+      _target_: aiflows.base_flows.BranchingFlow.instantiate_from_default_config
       subflows_config:
         wiki_search:
-          _target_: aiflows.ControllerExecutorFlowModule.WikiSearchAtomicFlow.instantiate_from_default_config
+          _target_: flow_modules.aiflows.ControllerExecutorFlowModule.WikiSearchAtomicFlow.instantiate_from_default_config
 
 
     Memory:

run.py

@@ -2,13 +2,13 @@ import os
 
 import hydra
 
-import flows
-from flows.flow_launchers import FlowLauncher
-from flows.backends.api_info import ApiInfo
-from flows.utils.general_helpers import read_yaml_file
+import aiflows
+from aiflows.flow_launchers import FlowLauncher
+from aiflows.backends.api_info import ApiInfo
+from aiflows.utils.general_helpers import read_yaml_file
 
-from flows import logging
-from flows.flow_cache import CACHING_PARAMETERS, clear_cache
+from aiflows import logging
+from aiflows.flow_cache import CACHING_PARAMETERS, clear_cache
 
 CACHING_PARAMETERS.do_caching = False  # Set to True in order to disable caching
 # clear_cache() # Uncomment this line to clear the cache
@@ -19,7 +19,7 @@ dependencies = [
     {"url": "aiflows/AutoGPTFlowModule", "revision": os.getcwd()},
     {"url": "aiflows/LCToolFlowModule", "revision": "main"},
 ]
-from flows import flow_verse
+from aiflows import flow_verse
 
 flow_verse.sync_dependencies(dependencies)
 if __name__ == "__main__":