refactor(agent): remove CrewAI agent support and update related configurations

Author: Davidson Gomes

CHANGELOG.md

@@ -9,7 +9,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Added
 
-- Add CrewAI agents
 - Add Task Agent for structured single-task execution
 - Improve context management in agent execution
 

README.md

@@ -15,7 +15,6 @@ The Evo AI platform allows:
 - JWT authentication with email verification
 - **[Agent 2 Agent (A2A) Protocol Support](https://developers.googleblog.com/en/a2a-a-new-era-of-agent-interoperability/)**: Interoperability between AI agents following Google's A2A specification
 - **[Workflow Agent with LangGraph](https://www.langchain.com/langgraph)**: Building complex agent workflows with LangGraph and ReactFlow
-- **[CrewAI Agent Support](https://www.crewai.com/)**: Organizing agents into specialized crews with assigned tasks
 - **Secure API Key Management**: Encrypted storage of API keys with Fernet encryption
 - **Agent Organization**: Folder structure for organizing agents by categories
 
@@ -154,40 +153,7 @@ Executes sub-agents in a custom workflow defined by a graph structure. This agen
 
 The workflow structure is built using ReactFlow in the frontend, allowing visual creation and editing of complex agent workflows with nodes (representing agents or decision points) and edges (representing flow connections).
 
-### 7. CrewAI Agent
-
-Allows organizing agents into a "crew" with specific tasks assigned to each agent. Based on the CrewAI concept, where each agent has a specific responsibility to perform a more complex task collaboratively.
-
-```json
-{
-  "client_id": "{{client_id}}",
-  "name": "research_crew",
-  "type": "crew_ai",
-  "folder_id": "folder_id (optional)",
-  "config": {
-    "tasks": [
-      {
-        "agent_id": "agent-uuid-1",
-        "description": "Search for recent information on the topic",
-        "expected_output": "Search report in JSON format"
-      },
-      {
-        "agent_id": "agent-uuid-2",
-        "description": "Analyze data and create visualizations",
-        "expected_output": "Charts and analyses in HTML format"
-      },
-      {
-        "agent_id": "agent-uuid-3",
-        "description": "Write final report combining results",
-        "expected_output": "Markdown document with complete analysis"
-      }
-    ],
-    "sub_agents": ["agent-uuid-4", "agent-uuid-5"]
-  }
-}
-```
-
-### 8. Task Agent
+### 7. Task Agent
 
 Executes a specific task using a target agent. Task Agent provides a streamlined approach for structured task execution, where the agent_id specifies which agent will process the task, and the task description can include dynamic content placeholders.
 

pyproject.toml

@@ -51,7 +51,6 @@ dependencies = [
     "langgraph==0.4.1",
     "opentelemetry-sdk==1.33.0",
     "opentelemetry-exporter-otlp==1.33.0",
-    "crewai==0.119.0",
 ]
 
 [project.optional-dependencies]

src/api/agent_routes.py

@@ -24,8 +24,6 @@
 │ For any future changes to the code in this file, it is recommended to        │
 │ include, together with the modification, the information of the developer    │
 │ who changed it and the date of modification.                                 │
-│                                                                              │
-│ @update: May 14, 2025 - Added support for crew_ai agent type                 │
 └──────────────────────────────────────────────────────────────────────────────┘
 """
 

src/schemas/agent_config.py

@@ -238,12 +238,15 @@ class Config:
         from_attributes = True
 
 
-class CrewAITask(BaseModel):
-    """Task configuration for Crew AI agents"""
+class AgentTask(BaseModel):
+    """Task configuration for agents"""
 
     agent_id: Union[UUID, str] = Field(
         ..., description="ID of the agent assigned to this task"
     )
+    enabled_tools: Optional[List[str]] = Field(
+        default_factory=list, description="List of tool names to be used in the task"
+    )
     description: str = Field(..., description="Description of the task to be performed")
     expected_output: str = Field(..., description="Expected output from this task")
 
@@ -260,17 +263,17 @@ class Config:
         from_attributes = True
 
 
-class CrewAIConfig(BaseModel):
-    """Configuration for Crew AI agents"""
+class AgentConfig(BaseModel):
+    """Configuration for agents"""
 
-    tasks: List[CrewAITask] = Field(
-        ..., description="List of tasks to be performed by the crew"
+    tasks: List[AgentTask] = Field(
+        ..., description="List of tasks to be performed by the agent"
     )
     api_key: Optional[str] = Field(
-        default_factory=generate_api_key, description="API key for the Crew AI agent"
+        default_factory=generate_api_key, description="API key for the agent"
     )
     sub_agents: Optional[List[UUID]] = Field(
-        default_factory=list, description="List of IDs of sub-agents used in crew"
+        default_factory=list, description="List of IDs of sub-agents used in agent"
     )
 
     class Config:

src/schemas/schemas.py

@@ -33,7 +33,7 @@
 from uuid import UUID
 import uuid
 import re
-from src.schemas.agent_config import LLMConfig, CrewAIConfig
+from src.schemas.agent_config import LLMConfig, AgentConfig
 
 
 class ClientBase(BaseModel):
@@ -98,7 +98,7 @@ class AgentBase(BaseModel):
     goal: Optional[str] = Field(None, description="Agent goal or objective")
     type: str = Field(
         ...,
-        description="Agent type (llm, sequential, parallel, loop, a2a, workflow, crew_ai, task)",
+        description="Agent type (llm, sequential, parallel, loop, a2a, workflow, task)",
     )
     model: Optional[str] = Field(
         None, description="Agent model (required only for llm type)"
@@ -136,11 +136,10 @@ def validate_type(cls, v):
             "loop",
             "a2a",
             "workflow",
-            "crew_ai",
             "task",
         ]:
             raise ValueError(
-                "Invalid agent type. Must be: llm, sequential, parallel, loop, a2a, workflow, crew_ai or task"
+                "Invalid agent type. Must be: llm, sequential, parallel, loop, a2a, workflow or task"
             )
         return v
 
@@ -200,7 +199,7 @@ def validate_config(cls, v, values):
                 raise ValueError(
                     f'Agent {values["type"]} must have at least one sub-agent'
                 )
-        elif values["type"] == "crew_ai" or values["type"] == "task":
+        elif values["type"] == "task":
             if not isinstance(v, dict):
                 raise ValueError(f'Invalid configuration for agent {values["type"]}')
             if "tasks" not in v:
@@ -217,7 +216,6 @@ def validate_config(cls, v, values):
                     if field not in task:
                         raise ValueError(f"Task missing required field: {field}")
 
-            # Validar sub_agents, se existir
             if "sub_agents" in v and v["sub_agents"] is not None:
                 if not isinstance(v["sub_agents"], list):
                     raise ValueError("sub_agents must be a list")

src/services/agent_builder.py

@@ -40,7 +40,6 @@
 from src.services.mcp_service import MCPService
 from src.services.custom_agents.a2a_agent import A2ACustomAgent
 from src.services.custom_agents.workflow_agent import WorkflowAgent
-from src.services.custom_agents.crew_ai_agent import CrewAIAgent
 from src.services.custom_agents.task_agent import TaskAgent
 from src.services.apikey_service import get_decrypted_api_key
 from sqlalchemy.orm import Session
@@ -50,7 +49,7 @@
 from datetime import datetime
 import uuid
 
-from src.schemas.agent_config import CrewAITask
+from src.schemas.agent_config import AgentTask
 
 logger = setup_logger(__name__)
 
@@ -74,7 +73,7 @@ async def _agent_tools_builder(self, agent) -> List[AgentTool]:
         return agent_tools
 
     async def _create_llm_agent(
-        self, agent
+        self, agent, enabled_tools: List[str] = []
     ) -> Tuple[LlmAgent, Optional[AsyncExitStack]]:
         """Create an LLM agent from the agent data."""
         # Get custom tools from the configuration
@@ -95,6 +94,10 @@ async def _create_llm_agent(
         # Combine all tools
         all_tools = custom_tools + mcp_tools + agent_tools
 
+        if enabled_tools:
+            all_tools = [tool for tool in all_tools if tool.name in enabled_tools]
+            logger.info(f"Enabled tools enabled. Total tools: {len(all_tools)}")
+
         now = datetime.now()
         current_datetime = now.strftime("%d/%m/%Y %H:%M")
         current_day_of_week = now.strftime("%A")
@@ -200,6 +203,8 @@ async def _get_sub_agents(
                 sub_agent, exit_stack = await self.build_a2a_agent(agent)
             elif agent.type == "workflow":
                 sub_agent, exit_stack = await self.build_workflow_agent(agent)
+            elif agent.type == "task":
+                sub_agent, exit_stack = await self.build_task_agent(agent)
             elif agent.type == "sequential":
                 sub_agent, exit_stack = await self.build_composite_agent(agent)
             elif agent.type == "parallel":
@@ -218,7 +223,7 @@ async def _get_sub_agents(
         return sub_agents
 
     async def build_llm_agent(
-        self, root_agent
+        self, root_agent, enabled_tools: List[str] = []
     ) -> Tuple[LlmAgent, Optional[AsyncExitStack]]:
         """Build an LLM agent with its sub-agents."""
         logger.info("Creating LLM agent")
@@ -230,7 +235,9 @@ async def build_llm_agent(
             )
             sub_agents = [agent for agent, _ in sub_agents_with_stacks]
 
-        root_llm_agent, exit_stack = await self._create_llm_agent(root_agent)
+        root_llm_agent, exit_stack = await self._create_llm_agent(
+            root_agent, enabled_tools
+        )
         if sub_agents:
             root_llm_agent.sub_agents = sub_agents
 
@@ -341,10 +348,11 @@ async def build_task_agent(
             # Convert tasks to the expected format by TaskAgent
             tasks = []
             for task_config in config.get("tasks", []):
-                task = CrewAITask(
+                task = AgentTask(
                     agent_id=task_config.get("agent_id"),
                     description=task_config.get("description", ""),
                     expected_output=task_config.get("expected_output", ""),
+                    enabled_tools=task_config.get("enabled_tools", []),
                 )
                 tasks.append(task)
 
@@ -362,57 +370,7 @@ async def build_task_agent(
 
         except Exception as e:
             logger.error(f"Error building Task agent: {str(e)}")
-            raise ValueError(f"Error building CrewAI agent: {str(e)}")
-
-    async def build_crew_ai_agent(
-        self, root_agent: Agent
-    ) -> Tuple[CrewAIAgent, Optional[AsyncExitStack]]:
-        """Build a CrewAI agent with its sub-agents."""
-        logger.info(f"Creating CrewAI agent: {root_agent.name}")
-
-        agent_config = root_agent.config or {}
-
-        # Verify if we have tasks configured
-        if not agent_config.get("tasks"):
-            raise ValueError("tasks are required for CrewAI agents")
-
-        try:
-            # Get sub-agents if there are any
-            sub_agents = []
-            if root_agent.config.get("sub_agents"):
-                sub_agents_with_stacks = await self._get_sub_agents(
-                    root_agent.config.get("sub_agents")
-                )
-                sub_agents = [agent for agent, _ in sub_agents_with_stacks]
-
-            # Additional configurations
-            config = root_agent.config or {}
-
-            # Convert tasks to the expected format by CrewAIAgent
-            tasks = []
-            for task_config in config.get("tasks", []):
-                task = CrewAITask(
-                    agent_id=task_config.get("agent_id"),
-                    description=task_config.get("description", ""),
-                    expected_output=task_config.get("expected_output", ""),
-                )
-                tasks.append(task)
-
-            # Create the CrewAI agent
-            crew_ai_agent = CrewAIAgent(
-                name=root_agent.name,
-                tasks=tasks,
-                db=self.db,
-                sub_agents=sub_agents,
-            )
-
-            logger.info(f"CrewAI agent created successfully: {root_agent.name}")
-
-            return crew_ai_agent, None
-
-        except Exception as e:
-            logger.error(f"Error building CrewAI agent: {str(e)}")
-            raise ValueError(f"Error building CrewAI agent: {str(e)}")
+            raise ValueError(f"Error building Task agent: {str(e)}")
 
     async def build_composite_agent(
         self, root_agent
@@ -477,26 +435,23 @@ async def build_composite_agent(
         else:
             raise ValueError(f"Invalid agent type: {root_agent.type}")
 
-    async def build_agent(self, root_agent) -> Tuple[
+    async def build_agent(self, root_agent, enabled_tools: List[str] = []) -> Tuple[
         LlmAgent
         | SequentialAgent
         | ParallelAgent
         | LoopAgent
         | A2ACustomAgent
         | WorkflowAgent
-        | CrewAIAgent
         | TaskAgent,
         Optional[AsyncExitStack],
     ]:
         """Build the appropriate agent based on the type of the root agent."""
         if root_agent.type == "llm":
-            return await self.build_llm_agent(root_agent)
+            return await self.build_llm_agent(root_agent, enabled_tools)
         elif root_agent.type == "a2a":
             return await self.build_a2a_agent(root_agent)
         elif root_agent.type == "workflow":
             return await self.build_workflow_agent(root_agent)
-        elif root_agent.type == "crew_ai":
-            return await self.build_crew_ai_agent(root_agent)
         elif root_agent.type == "task":
             return await self.build_task_agent(root_agent)
         else:

src/services/agent_service.py

@@ -202,7 +202,7 @@ async def create_agent(db: Session, agent: AgentCreate) -> Agent:
             if "api_key" not in agent.config or not agent.config["api_key"]:
                 agent.config["api_key"] = generate_api_key()
 
-        elif agent.type == "crew_ai" or agent.type == "task":
+        elif agent.type == "task":
             if not isinstance(agent.config, dict):
                 agent.config = {}
                 raise HTTPException(
@@ -682,8 +682,8 @@ async def update_agent(
         if "config" not in agent_data:
             agent_data["config"] = agent_config
 
-        if ("type" in agent_data and agent_data["type"] in ["crew_ai", "task"]) or (
-            agent.type in ["crew_ai", "task"] and "config" in agent_data
+        if ("type" in agent_data and agent_data["type"] in ["task"]) or (
+            agent.type in ["task"] and "config" in agent_data
         ):
             config = agent_data.get("config", {})
             if "tasks" not in config: