chore(agent): Remove LogCycleHandler (#7192)

- Remove no longer needed LogCycleHandler class and its usage in Agent

autogpt/autogpt/agents/agent.py

@@ -2,7 +2,6 @@ from __future__ import annotations
 
 import inspect
 import logging
-from datetime import datetime
 from typing import TYPE_CHECKING, Any, ClassVar, Optional
 
 import sentry_sdk
@@ -53,13 +52,6 @@ from forge.utils.exceptions import (
 )
 from pydantic import Field
 
-from autogpt.app.log_cycle import (
-    CURRENT_CONTEXT_FILE_NAME,
-    NEXT_ACTION_FILE_NAME,
-    USER_INPUT_FILE_NAME,
-    LogCycleHandler,
-)
-
 from .prompt_strategies.one_shot import (
     OneShotAgentActionProposal,
     OneShotAgentPromptStrategy,
@@ -140,12 +132,6 @@ class Agent(BaseAgent[OneShotAgentActionProposal], Configurable[AgentSettings]):
             ContextComponent
         )
 
-        self.created_at = datetime.now().strftime("%Y%m%d_%H%M%S")
-        """Timestamp the agent was created; only used for structured debug logging."""
-
-        self.log_cycle_handler = LogCycleHandler()
-        """LogCycleHandler for structured debug logging."""
-
         self.event_history = settings.history
         self.legacy_config = legacy_config
 
@@ -183,15 +169,6 @@ class Agent(BaseAgent[OneShotAgentActionProposal], Configurable[AgentSettings]):
             include_os_info=self.legacy_config.execute_local_commands,
         )
 
-        self.log_cycle_handler.log_count_within_cycle = 0
-        self.log_cycle_handler.log_cycle(
-            self.state.ai_profile.ai_name,
-            self.created_at,
-            self.config.cycle_count,
-            prompt.raw(),
-            CURRENT_CONTEXT_FILE_NAME,
-        )
-
         logger.debug(f"Executing prompt:\n{dump_prompt(prompt)}")
         output = await self.complete_and_parse(prompt)
         self.config.cycle_count += 1
@@ -215,14 +192,6 @@ class Agent(BaseAgent[OneShotAgentActionProposal], Configurable[AgentSettings]):
         )
         result = response.parsed_result
 
-        self.log_cycle_handler.log_cycle(
-            self.state.ai_profile.ai_name,
-            self.created_at,
-            self.config.cycle_count,
-            result.thoughts.dict(),
-            NEXT_ACTION_FILE_NAME,
-        )
-
         await self.run_pipeline(AfterParse.after_parse, result)
 
         return result
@@ -266,13 +235,6 @@ class Agent(BaseAgent[OneShotAgentActionProposal], Configurable[AgentSettings]):
         self, denied_proposal: OneShotAgentActionProposal, user_feedback: str
     ) -> ActionResult:
         result = ActionInterruptedByHuman(feedback=user_feedback)
-        self.log_cycle_handler.log_cycle(
-            self.state.ai_profile.ai_name,
-            self.created_at,
-            self.config.cycle_count,
-            user_feedback,
-            USER_INPUT_FILE_NAME,
-        )
 
         await self.run_pipeline(AfterExecute.after_execute, result)
 

autogpt/autogpt/app/log_cycle.py

@@ -1,81 +0,0 @@
-import json
-import os
-from pathlib import Path
-from typing import Any, Dict, Union
-
-from forge.logging.config import LOG_DIR
-
-DEFAULT_PREFIX = "agent"
-CURRENT_CONTEXT_FILE_NAME = "current_context.json"
-NEXT_ACTION_FILE_NAME = "next_action.json"
-PROMPT_SUMMARY_FILE_NAME = "prompt_summary.json"
-SUMMARY_FILE_NAME = "summary.txt"
-SUPERVISOR_FEEDBACK_FILE_NAME = "supervisor_feedback.txt"
-PROMPT_SUPERVISOR_FEEDBACK_FILE_NAME = "prompt_supervisor_feedback.json"
-USER_INPUT_FILE_NAME = "user_input.txt"
-
-
-class LogCycleHandler:
-    """
-    A class for logging cycle data.
-    """
-
-    def __init__(self):
-        self.log_count_within_cycle = 0
-
-    def create_outer_directory(self, ai_name: str, created_at: str) -> Path:
-        if os.environ.get("OVERWRITE_DEBUG") == "1":
-            outer_folder_name = "auto_gpt"
-        else:
-            ai_name_short = self.get_agent_short_name(ai_name)
-            outer_folder_name = f"{created_at}_{ai_name_short}"
-
-        outer_folder_path = LOG_DIR / "DEBUG" / outer_folder_name
-        if not outer_folder_path.exists():
-            outer_folder_path.mkdir(parents=True)
-
-        return outer_folder_path
-
-    def get_agent_short_name(self, ai_name: str) -> str:
-        return ai_name[:15].rstrip() if ai_name else DEFAULT_PREFIX
-
-    def create_inner_directory(self, outer_folder_path: Path, cycle_count: int) -> Path:
-        nested_folder_name = str(cycle_count).zfill(3)
-        nested_folder_path = outer_folder_path / nested_folder_name
-        if not nested_folder_path.exists():
-            nested_folder_path.mkdir()
-
-        return nested_folder_path
-
-    def create_nested_directory(
-        self, ai_name: str, created_at: str, cycle_count: int
-    ) -> Path:
-        outer_folder_path = self.create_outer_directory(ai_name, created_at)
-        nested_folder_path = self.create_inner_directory(outer_folder_path, cycle_count)
-
-        return nested_folder_path
-
-    def log_cycle(
-        self,
-        ai_name: str,
-        created_at: str,
-        cycle_count: int,
-        data: Union[Dict[str, Any], Any],
-        file_name: str,
-    ) -> None:
-        """
-        Log cycle data to a JSON file.
-
-        Args:
-            data (Any): The data to be logged.
-            file_name (str): The name of the file to save the logged data.
-        """
-        cycle_log_dir = self.create_nested_directory(ai_name, created_at, cycle_count)
-
-        json_data = json.dumps(data, ensure_ascii=False, indent=4)
-        log_file_path = cycle_log_dir / f"{self.log_count_within_cycle}_{file_name}"
-
-        with open(log_file_path, "w", encoding="utf-8") as f:
-            f.write(json_data + "\n")
-
-        self.log_count_within_cycle += 1