clean up back to old tool logic

swarms/agents/workers/worker.py

@@ -13,28 +13,13 @@ import logging
 from pydantic import BaseModel, Extra
 logging.basicConfig(level=logging.DEBUG, format='%(asctime)s - %(levelname)s - %(message)s')
 
-# class WorkerNodeArgs(BaseModel):
+class WorkerNode:
-#     prompt: str
-#     run_manager: Optional[CallbackManagerForToolRun] = None
-
-#     class Config:
-#         arbitrary_types_allowed = True
-#         extra = Extra.forbid
-
-# @tool("WorkerNode")
-class WorkerNode(
-    # BaseTool
-    ):
     """Useful for when you need to spawn an autonomous agent instance as a worker to accomplish complex tasks, it can search the internet or spawn child multi-modality models to process and generate images and text or audio and so on"""
-    
-    # args_schema: Optional[Type[BaseModel]] = WorkerNodeArgs
-    # """Pydantic model class to validate and parse the tool's input arguments."""
 
-    def __init__(self, **kwargs):
+    def __init__(self, llm, tools, vectorstore):
-        super().__init__(**kwargs)
+        self.llm = llm
-        self.llm = kwargs.get('llm')
+        self.tools = tools
-        self.tools = kwargs.get('tools')
+        self.vectorstore = vectorstore
-        self.vectorstore = kwargs.get('vectorstore')
         self.agent = None
 
     def create_agent(self, ai_name, ai_role, human_in_the_loop, search_kwargs):
@@ -50,27 +35,18 @@ class WorkerNode(
         )
         self.agent.chain.verbose = True
 
-    def _run(
+    def run(self, tool_input: Dict[str, Any]) -> str:
-        self, tool_input: Dict[str, Any], run_manager: Optional[CallbackManagerForToolRun] = None
-    ) -> str:
         """Use the tool."""
-        prompt = self._parse_input(tool_input)
+        prompt = tool_input['prompt']
         tree_of_thoughts_prompt = """
-        Imagine three different experts are answering this question. All experts will write down each chain of thought of each step of their thinking, then share it with the group. Then all experts will go on to the next step, etc. If any expert realises they're wrong at any point then they leave. The question is...
+        Imagine three different experts are answering this question. All experts will write down each chain of thought of each step of their thinking, then share it with the group. Then all experts will go on to the next step, etc. If any expert realizes they're wrong at any point then they leave. The question is...
         """
         self.agent.run([f"{tree_of_thoughts_prompt}{prompt}"])
         return "Task completed by WorkerNode"
 
-    async def _arun(
-        self, prompt: str, run_manager: Optional[AsyncCallbackManagerForToolRun] = None
-    ) -> str:
-        """Use the tool asynchronously."""
-        raise NotImplementedError("WorkerNode does not support async")
-
-
 worker_tool = Tool(
     name="WorkerNode AI Agent",
-    func=WorkerNode._run,
+    func=WorkerNode.run,
     description="Useful for when you need to spawn an autonomous agent instance as a worker to accomplish complex tasks, it can search the internet or spawn child multi-modality models to process and generate images and text or audio and so on"
 )
 

swarms/swarms.py

@@ -42,7 +42,7 @@ class Swarms:
         llm = self.initialize_llm(ChatOpenAI)
         worker_node = WorkerNode(llm=llm, tools=worker_tools, vectorstore=vectorstore)
         worker_node.create_agent(ai_name="AI Assistant", ai_role="Assistant", human_in_the_loop=False, search_kwargs={})
-        return worker_node
+        return worker_tool(name="WorkerNode AI Agent", func=worker_node.run, description="Useful for when you need to spawn an autonomous agent instance as a worker to accomplish complex tasks, it can search the internet or spawn child multi-modality models to process and generate images and text or audio and so on")
 
     def initialize_boss_node(self, vectorstore, worker_node):
         # Initialize boss node
@@ -51,7 +51,7 @@ class Swarms:
         todo_chain = LLMChain(llm=llm, prompt=todo_prompt)
         tools = [
             Tool(name="TODO", func=todo_chain.run, description="useful for when you need to come up with todo lists. Input: an objective to create a todo list for. Output: a todo list for that objective. Please be very clear what the objective is!"),
-            worker_tool
+            worker_node
         ]
         suffix = """Question: {task}\n{agent_scratchpad}"""
         prefix = """You are an Boss in a swarm who performs one task based on the following objective: {objective}. Take into account these previously completed tasks: {context}.\n"""
@@ -69,6 +69,7 @@ class Swarms:
 
             vectorstore = self.initialize_vectorstore()
             worker_node = self.initialize_worker_node(worker_tools, vectorstore)
+
             boss_node = self.initialize_boss_node(vectorstore, worker_node)
 
             task = boss_node.create_task(objective)