add process_task

Author: Peteredwardj

src/agent.py

@@ -238,7 +238,7 @@ def execution_step(self, state: AgentState) -> AgentState:
             response = self.executor_agent.invoke(execution_prompt)
             state = self.executor_agent.process_response(response, state)
 
-        return {"action_log": state["action_log"]}
+        return state
 
     def evaluation_step(self, state: AgentState):
         #Convert action_logs to a summary of what the agent did, and then pass it to task_log
@@ -259,6 +259,24 @@ def evaluation_step(self, state: AgentState):
         print_h_bar()
         time.sleep(self.loop_delay)
         return state
+    
+    def process_task(self, task: str): # Process a single task
+        state = {
+            "context": {},
+            "current_task": task,
+            "context_summary": "",
+            "action_plan": [],
+            "action_log": [],
+            "task_log": [],
+        }
+        
+        state.update(self.observation_step(state))
+        state.update(self.determination_step(state))
+        state.update(self.division_step(state))
+        state = self.execution_step(state)
+        state.update(self.evaluation_step(state))
+        
+        return state
 
     def loop(self, task=None):
         # Check if LangChain enabled