dont cache deps

- Fix OSError when trying to get source code of lambda functions in guardrail events
- Gracefully handle lambdas and built-in functions by showing placeholder text

.github/workflows/build-uv-cache.yml

@@ -33,7 +33,7 @@ jobs:
       - name: Install dependencies and populate cache
         run: |
           echo "Building global UV cache for Python ${{ matrix.python-version }}..."
-          uv sync --all-groups --all-extras --no-install-project
+          uv sync --all-groups --all-extras
           echo "Cache populated successfully"
 
       - name: Save uv caches

.github/workflows/linter.yml

@@ -38,7 +38,7 @@ jobs:
           enable-cache: false
 
       - name: Install dependencies
-        run: uv sync --all-groups --all-extras --no-install-project
+        run: uv sync --all-packages --all-extras --no-install-project
 
       - name: Get Changed Python Files
         id: changed-files

.github/workflows/tests.yml

@@ -25,17 +25,17 @@ jobs:
         with:
           fetch-depth: 0  # Fetch all history for proper diff
 
-      - name: Restore global uv cache
+      # - name: Restore global uv cache
-        id: cache-restore
+      #   id: cache-restore
-        uses: actions/cache/restore@v4
+      #   uses: actions/cache/restore@v4
-        with:
+      #   with:
-          path: |
+      #     path: |
-            ~/.cache/uv
+      #       ~/.cache/uv
-            ~/.local/share/uv
+      #       ~/.local/share/uv
-            .venv
+      #       .venv
-          key: uv-main-py${{ matrix.python-version }}-${{ hashFiles('uv.lock') }}
+      #     key: uv-main-py${{ matrix.python-version }}-${{ hashFiles('uv.lock') }}
-          restore-keys: |
+      #     restore-keys: |
-            uv-main-py${{ matrix.python-version }}-
+      #       uv-main-py${{ matrix.python-version }}-
 
       - name: Install uv
         uses: astral-sh/setup-uv@v6
@@ -45,24 +45,24 @@ jobs:
           enable-cache: false
 
       - name: Install the project
-        run: uv sync --all-groups --all-extras
+        run: uv sync --all-packages --all-extras
 
-      - name: Restore test durations
+      # - name: Restore test durations
-        uses: actions/cache/restore@v4
+      #   uses: actions/cache/restore@v4
-        with:
+      #   with:
-          path: .test_durations_py*
+      #     path: .test_durations_py*
-          key: test-durations-py${{ matrix.python-version }}
+      #     key: test-durations-py${{ matrix.python-version }}
 
       - name: Run tests (group ${{ matrix.group }} of 8)
         run: |
           PYTHON_VERSION_SAFE=$(echo "${{ matrix.python-version }}" | tr '.' '_')
           DURATION_FILE=".test_durations_py${PYTHON_VERSION_SAFE}"
-          
+
           # Temporarily always skip cached durations to fix test splitting
           # When durations don't match, pytest-split runs duplicate tests instead of splitting
           echo "Using even test splitting (duration cache disabled until fix merged)"
           DURATIONS_ARG=""
-          
+
           # Original logic (disabled temporarily):
           # if [ ! -f "$DURATION_FILE" ]; then
           #   echo "No cached durations found, tests will be split evenly"
@@ -74,8 +74,8 @@ jobs:
           #   echo "No test changes detected, using cached test durations for optimal splitting"
           #   DURATIONS_ARG="--durations-path=${DURATION_FILE}"
           # fi
-          
+
-          uv run pytest \
+          uv run pytest lib/crewai \
             --block-network \
             --timeout=30 \
             -vv \
@@ -84,14 +84,15 @@ jobs:
             $DURATIONS_ARG \
             --durations=10 \
             -n auto \
-            --maxfail=3
+            --maxfail=3 \
+            -m "not requires_local_services"
 
-      - name: Save uv caches
+      # - name: Save uv caches
-        if: steps.cache-restore.outputs.cache-hit != 'true'
+      #   if: steps.cache-restore.outputs.cache-hit != 'true'
-        uses: actions/cache/save@v4
+      #   uses: actions/cache/save@v4
-        with:
+      #   with:
-          path: |
+      #     path: |
-            ~/.cache/uv
+      #       ~/.cache/uv
-            ~/.local/share/uv
+      #       ~/.local/share/uv
-            .venv
+      #       .venv
-          key: uv-main-py${{ matrix.python-version }}-${{ hashFiles('uv.lock') }}
+      #     key: uv-main-py${{ matrix.python-version }}-${{ hashFiles('uv.lock') }}

.github/workflows/type-checker.yml

@@ -40,7 +40,7 @@ jobs:
           enable-cache: false
 
       - name: Install dependencies
-        run: uv sync --all-groups --all-extras
+        run: uv sync --all-packages --all-extras
 
       - name: Get changed Python files
         id: changed-files

.gitignore

@@ -2,7 +2,6 @@
 .pytest_cache
 __pycache__
 dist/
-lib/
 .env
 assets/*
 .idea

.pre-commit-config.yaml

@@ -6,14 +6,19 @@ repos:
         entry: uv run ruff check
         language: system
         types: [python]
+        files: ^lib/crewai/src/
+        exclude: ^lib/crewai/
       - id: ruff-format
         name: ruff-format
         entry: uv run ruff format
         language: system
         types: [python]
+        files: ^lib/crewai/src/
+        exclude: ^lib/crewai/
       - id: mypy
         name: mypy
         entry: uv run mypy
         language: system
         types: [python]
-        exclude: ^tests/
+        files: ^lib/crewai/src/
+        exclude: ^lib/crewai/

lib/crewai/.python-version

@@ -0,0 +1 @@
+3.13

lib/crewai/pyproject.toml

@@ -0,0 +1,124 @@
+[project]
+name = "crewai"
+dynamic = ["version"]
+description = ""
+readme = "README.md"
+authors = [
+    { name = "Greyson Lalonde", email = "greyson.r.lalonde@gmail.com" }
+]
+keywords = [
+    "crewai",
+    "ai",
+    "agents",
+    "framework",
+    "orchestration",
+    "llm",
+    "core",
+    "typed",
+]
+classifiers = [
+    "Development Status :: 3 - Alpha",
+    "Intended Audience :: Developers",
+    "Operating System :: OS Independent",
+    "Programming Language :: Python :: 3",
+    "Programming Language :: Python :: 3.12",
+    "Programming Language :: Python :: 3.13",
+    "Topic :: Software Development :: Libraries :: Python Modules",
+    "Typing :: Typed",
+]
+requires-python = ">=3.10, <3.14"
+dependencies = [
+    # Core Dependencies
+    "crewai",
+    "pydantic>=2.11.9",
+    "openai>=1.13.3",
+    "litellm==1.74.9",
+    "instructor>=1.3.3",
+    # Text Processing
+    "pdfplumber>=0.11.4",
+    "regex>=2024.9.11",
+    # Telemetry and Monitoring
+    "opentelemetry-api>=1.30.0",
+    "opentelemetry-sdk>=1.30.0",
+    "opentelemetry-exporter-otlp-proto-http>=1.30.0",
+    "tokenizers>=0.20.3",
+    "openpyxl>=3.1.5",
+    "pyvis>=0.3.2",
+    # Authentication and Security
+    "python-dotenv>=1.1.1",
+    "pyjwt>=2.9.0",
+    # Configuration and Utils
+    "click>=8.1.7",
+    "appdirs>=1.4.4",
+    "jsonref>=1.1.0",
+    "json-repair==0.25.2",
+    "tomli-w>=1.1.0",
+    "tomli>=2.0.2",
+    "blinker>=1.9.0",
+    "json5>=0.10.0",
+    "portalocker==2.7.0",
+    "chromadb~=1.1.0",
+    "pydantic-settings>=2.10.1",
+    "uv>=0.4.25",
+]
+
+[project.optional-dependencies]
+tools = [
+    "crewai-tools",
+]
+embeddings = [
+    "tiktoken~=0.8.0"
+]
+pdfplumber = [
+    "pdfplumber>=0.11.4",
+]
+pandas = [
+    "pandas>=2.2.3",
+]
+openpyxl = [
+    "openpyxl>=3.1.5",
+]
+mem0 = ["mem0ai>=0.1.94"]
+docling = [
+    "docling>=2.12.0",
+]
+aisuite = [
+    "aisuite>=0.1.10",
+]
+qdrant = [
+    "qdrant-client[fastembed]>=1.14.3",
+]
+aws = [
+    "boto3>=1.40.38",
+]
+watson = [
+    "ibm-watsonx-ai>=1.3.39",
+]
+voyageai = [
+    "voyageai>=0.3.5",
+]
+
+[project.scripts]
+crewai = "crewai.cli.cli:crewai"
+
+[project.urls]
+Homepage = "https://crewai.com"
+Documentation = "https://docs.crewai.com"
+Repository = "https://github.com/crewAIInc/crewAI"
+
+
+[tool.pytest.ini_options]
+testpaths = ["tests"]
+asyncio_mode = "strict"
+asyncio_default_fixture_loop_scope = "function"
+
+
+[build-system]
+requires = ["hatchling"]
+build-backend = "hatchling.build"
+
+[tool.hatch.version]
+path = "src/crewai/__init__.py"
+
+[tool.hatch.build.targets.wheel]
+packages = ["src/crewai"]

lib/crewai/src/crewai/__init__.py

@@ -40,7 +40,7 @@ def _suppress_pydantic_deprecation_warnings() -> None:
 
 _suppress_pydantic_deprecation_warnings()
 
-__version__ = "0.201.1"
+__version__ = "1.0.0a0"
 _telemetry_submitted = False
 
 

lib/crewai/src/crewai/agent.py

@@ -5,12 +5,13 @@ from collections.abc import Callable, Sequence
 from typing import (
     Any,
     Literal,
+    cast,
 )
 
 from pydantic import Field, InstanceOf, PrivateAttr, model_validator
 
 from crewai.agents import CacheHandler
-from crewai.agents.agent_builder.base_agent import BaseAgent
+from crewai.agents.agent_builder.base_agent import BaseAgent, PlatformAppOrAction
 from crewai.agents.crew_agent_executor import CrewAgentExecutor
 from crewai.events.event_bus import crewai_event_bus
 from crewai.events.types.agent_events import (
@@ -78,6 +79,7 @@ class Agent(BaseAgent):
             step_callback: Callback to be executed after each step of the agent execution.
             knowledge_sources: Knowledge sources for the agent.
             embedder: Embedder configuration for the agent.
+            apps: List of applications that the agent can access through CrewAI Platform.
     """
 
     _times_executed: int = PrivateAttr(default=0)
@@ -174,7 +176,7 @@ class Agent(BaseAgent):
     )
 
     @model_validator(mode="before")
-    def validate_from_repository(cls, v): # noqa: N805
+    def validate_from_repository(cls, v):  # noqa: N805
         if v is not None and (from_repository := v.get("from_repository")):
             return load_agent_from_repository(from_repository) | v
         return v
@@ -271,11 +273,7 @@ class Agent(BaseAgent):
                 # Add the reasoning plan to the task description
                 task.description += f"\n\nReasoning Plan:\n{reasoning_output.plan.plan}"
             except Exception as e:
-                if hasattr(self, "_logger"):
+                self._logger.log("error", f"Error during reasoning process: {e!s}")
-                    self._logger.log("error", f"Error during reasoning process: {e!s}")
-                else:
-                    print(f"Error during reasoning process: {e!s}")
-
         self._inject_date_to_task(task)
 
         if self.tools_handler:
@@ -327,7 +325,7 @@ class Agent(BaseAgent):
                 agent=self,
                 task=task,
             )
-            memory = contextual_memory.build_context_for_task(task, context)  # type: ignore[arg-type]
+            memory = contextual_memory.build_context_for_task(task, context or "")
             if memory.strip() != "":
                 task_prompt += self.i18n.slice("memory").format(memory=memory)
 
@@ -579,7 +577,7 @@ class Agent(BaseAgent):
             agent=self,
             crew=self.crew,
             tools=parsed_tools,
-            prompt=prompt,  # type: ignore[arg-type]
+            prompt=cast(dict[str, str], prompt),
             original_tools=raw_tools,
             stop_words=stop_words,
             max_iter=self.max_iter,
@@ -599,6 +597,17 @@ class Agent(BaseAgent):
         agent_tools = AgentTools(agents=agents)
         return agent_tools.tools()
 
+    def get_platform_tools(self, apps: list[PlatformAppOrAction]) -> list[BaseTool]:
+        try:
+            from crewai_tools import (  # type: ignore[import-not-found]
+                CrewaiPlatformTools,  # type: ignore[import-untyped]
+            )
+
+            return CrewaiPlatformTools(apps=apps)
+        except Exception as e:
+            self._logger.log("error", f"Error getting platform tools: {e!s}")
+            return []
+
     def get_multimodal_tools(self) -> Sequence[BaseTool]:
         from crewai.tools.agent_tools.add_image_tool import AddImageTool
 
@@ -606,7 +615,9 @@ class Agent(BaseAgent):
 
     def get_code_execution_tools(self):
         try:
-            from crewai_tools import CodeInterpreterTool  # type: ignore
+            from crewai_tools import (  # type: ignore[import-not-found]
+                CodeInterpreterTool,
+            )
 
             # Set the unsafe_mode based on the code_execution_mode attribute
             unsafe_mode = self.code_execution_mode == "unsafe"
@@ -695,14 +706,15 @@ class Agent(BaseAgent):
 
     def _validate_docker_installation(self) -> None:
         """Check if Docker is installed and running."""
-        if not shutil.which("docker"):
+        docker_path = shutil.which("docker")
+        if not docker_path:
             raise RuntimeError(
                 f"Docker is not installed. Please install Docker to use code execution with agent: {self.role}"
             )
 
         try:
-            subprocess.run(
+            subprocess.run(  # noqa: S603
-                ["/usr/bin/docker", "info"],
+                [docker_path, "info"],
                 check=True,
                 stdout=subprocess.PIPE,
                 stderr=subprocess.PIPE,
@@ -711,6 +723,10 @@ class Agent(BaseAgent):
             raise RuntimeError(
                 f"Docker is not running. Please start Docker to use code execution with agent: {self.role}"
             ) from e
+        except subprocess.TimeoutExpired as e:
+            raise RuntimeError(
+                f"Docker command timed out. Please check your Docker installation for agent: {self.role}"
+            ) from e
 
     def __repr__(self):
         return f"Agent(role={self.role}, goal={self.goal}, backstory={self.backstory})"

lib/crewai/src/crewai/agents/agent_builder/base_agent.py

@@ -3,7 +3,7 @@ from abc import ABC, abstractmethod
 from collections.abc import Callable
 from copy import copy as shallow_copy
 from hashlib import md5
-from typing import Any, TypeVar
+from typing import Any, Literal, TypeVar
 
 from pydantic import (
     UUID4,
@@ -31,6 +31,27 @@ from crewai.utilities.string_utils import interpolate_only
 
 T = TypeVar("T", bound="BaseAgent")
 
+PlatformApp = Literal[
+    "asana",
+    "box",
+    "clickup",
+    "github",
+    "gmail",
+    "google_calendar",
+    "google_sheets",
+    "hubspot",
+    "jira",
+    "linear",
+    "notion",
+    "salesforce",
+    "shopify",
+    "slack",
+    "stripe",
+    "zendesk",
+]
+
+PlatformAppOrAction = PlatformApp | str
+
 
 class BaseAgent(ABC, BaseModel):
     """Abstract Base Class for all third party agents compatible with CrewAI.
@@ -41,11 +62,11 @@ class BaseAgent(ABC, BaseModel):
         goal (str): Objective of the agent.
         backstory (str): Backstory of the agent.
         cache (bool): Whether the agent should use a cache for tool usage.
-        config (Optional[Dict[str, Any]]): Configuration for the agent.
+        config (dict[str, Any] | None): Configuration for the agent.
         verbose (bool): Verbose mode for the Agent Execution.
-        max_rpm (Optional[int]): Maximum number of requests per minute for the agent execution.
+        max_rpm (int | None): Maximum number of requests per minute for the agent execution.
         allow_delegation (bool): Allow delegation of tasks to agents.
-        tools (Optional[List[Any]]): Tools at the agent's disposal.
+        tools (list[Any] | None): Tools at the agent's disposal.
         max_iter (int): Maximum iterations for an agent to execute a task.
         agent_executor (InstanceOf): An instance of the CrewAgentExecutor class.
         llm (Any): Language model that will run the agent.
@@ -57,18 +78,22 @@ class BaseAgent(ABC, BaseModel):
         knowledge_sources: Knowledge sources for the agent.
         knowledge_storage: Custom knowledge storage for the agent.
         security_config: Security configuration for the agent, including fingerprinting.
+        apps: List of enterprise applications that the agent can access through CrewAI Enterprise Tools.
+        actions: List of actions that the agent can access through CrewAI Enterprise Tools.
 
 
     Methods:
-        execute_task(task: Any, context: Optional[str] = None, tools: Optional[List[BaseTool]] = None) -> str:
+        execute_task(task: Any, context: str | None = None, tools: list[BaseTool] | None = None) -> str:
             Abstract method to execute a task.
         create_agent_executor(tools=None) -> None:
             Abstract method to create an agent executor.
-        get_delegation_tools(agents: List["BaseAgent"]):
+        get_delegation_tools(agents: list["BaseAgent"]):
             Abstract method to set the agents task tools for handling delegation and question asking to other agents in crew.
+        get_platform_tools(apps: list[PlatformAppOrAction]):
+            Abstract method to get platform tools for the specified list of applications and/or application/action combinations.
         get_output_converter(llm, model, instructions):
             Abstract method to get the converter class for the agent to create json/pydantic outputs.
-        interpolate_inputs(inputs: Dict[str, Any]) -> None:
+        interpolate_inputs(inputs: dict[str, Any]) -> None:
             Interpolate inputs into the agent description and backstory.
         set_cache_handler(cache_handler: CacheHandler) -> None:
             Set the cache handler for the agent.
@@ -161,6 +186,10 @@ class BaseAgent(ABC, BaseModel):
         default=None,
         description="Knowledge configuration for the agent such as limits and threshold",
     )
+    apps: list[PlatformAppOrAction] | None = Field(
+        default=None,
+        description="List of applications or application/action combinations that the agent can access through CrewAI Platform. Can contain app names (e.g., 'gmail') or specific actions (e.g., 'gmail/send_email')",
+    )
 
     @model_validator(mode="before")
     @classmethod
@@ -196,6 +225,24 @@ class BaseAgent(ABC, BaseModel):
                 )
         return processed_tools
 
+    @field_validator("apps")
+    @classmethod
+    def validate_apps(
+        cls, apps: list[PlatformAppOrAction] | None
+    ) -> list[PlatformAppOrAction] | None:
+        if not apps:
+            return apps
+
+        validated_apps = []
+        for app in apps:
+            if app.count("/") > 1:
+                raise ValueError(
+                    f"Invalid app format '{app}'. Apps can only have one '/' for app/action format (e.g., 'gmail/send_email')"
+                )
+            validated_apps.append(app)
+
+        return list(set(validated_apps))
+
     @model_validator(mode="after")
     def validate_and_set_attributes(self):
         # Validate required fields
@@ -266,6 +313,10 @@ class BaseAgent(ABC, BaseModel):
     def get_delegation_tools(self, agents: list["BaseAgent"]) -> list[BaseTool]:
         """Set the task tools that init BaseAgenTools class."""
 
+    @abstractmethod
+    def get_platform_tools(self, apps: list[PlatformAppOrAction]) -> list[BaseTool]:
+        """Get platform tools for the specified list of applications and/or application/action combinations."""
+
     def copy(self: T) -> T:  # type: ignore # Signature of "copy" incompatible with supertype "BaseModel"
         """Create a deep copy of the Agent."""
         exclude = {
@@ -282,6 +333,8 @@ class BaseAgent(ABC, BaseModel):
             "knowledge_sources",
             "knowledge_storage",
             "knowledge",
+            "apps",
+            "actions",
         }
 
         # Copy llm

lib/crewai/src/crewai/cli/templates/flow/crews/poem_crew/poem_crew.py

@@ -1,7 +1,6 @@
 from crewai import Agent, Crew, Process, Task
-from crewai.project import CrewBase, agent, crew, task
 from crewai.agents.agent_builder.base_agent import BaseAgent
-from typing import List
+from crewai.project import CrewBase, agent, crew, task
 
 # If you want to run a snippet of code before or after the crew starts,
 # you can use the @before_kickoff and @after_kickoff decorators
@@ -12,8 +11,8 @@ from typing import List
 class PoemCrew:
     """Poem Crew"""
 
-    agents: List[BaseAgent]
+    agents: list[BaseAgent]
-    tasks: List[Task]
+    tasks: list[Task]
 
     # Learn more about YAML configuration files here:
     # Agents: https://docs.crewai.com/concepts/agents#yaml-configuration-recommended

lib/crewai/src/crewai/cli/templates/flow/tools/custom_tool.py

@@ -1,7 +1,6 @@
-from typing import Type
+from pydantic import BaseModel, Field
 
 from crewai.tools import BaseTool
-from pydantic import BaseModel, Field
 
 
 class MyCustomToolInput(BaseModel):
@@ -12,10 +11,8 @@ class MyCustomToolInput(BaseModel):
 
 class MyCustomTool(BaseTool):
     name: str = "Name of my tool"
-    description: str = (
+    description: str = "Clear description for what this tool is useful for, your agent will need this information to use it."
-        "Clear description for what this tool is useful for, your agent will need this information to use it."
+    args_schema: type[BaseModel] = MyCustomToolInput
-    )
-    args_schema: Type[BaseModel] = MyCustomToolInput
 
     def _run(self, argument: str) -> str:
         # Implementation goes here