Save the access token and its expiration time. Args: access_token: The access token to save. expires_at: The UNIX tim

Mark telemetry live (idempotent). Deliberately does not install a global TracerProvider. Doing so made every OTel-instrumented librar

Set the ID of the triggering event for causal chain tracking. Args: event_id: The event_id that triggered the current execution, or None.

Store files for a crew execution. Args: execution_id: Unique identifier for the crew execution. files: Dictionary mapping names t

Iterate over frames, optionally filtered by channel.

Context manager to suppress all warnings. Yields: None during the context execution. Note: This implementation consolidates

Unregister a specific global after_tool_call hook. Args: hook: The hook function to remove Returns: True if the hook was fou

Unregister a specific global before_tool_call hook. Args: hook: The hook function to remove Returns: True if the hook was fo

Update the [project] version field in a pyproject.toml file. Args: file_path: Path to pyproject.toml file. new_version: New versi

Validate JSON crew structure without kicking off the crew.

Import and return the class/function from the import path. Args: v: Import path string in the format 'module.path.ClassName'. Return

Print a yellow deprecation warning for a legacy CLI command or flag.

Factory function that returns crewai platform tools. Args: apps: List of platform apps to get tools that are available on the platform.

Create an agent with explicitly activated, always-on skills.

Add A2A delegation instructions to prompt. Args: a2a_agents: Dictionary of A2A agent configurations task_description: Original ta

Build an UploadResult for a completed upload. Args: file_id: The uploaded file ID. content_type: The file's content t

Clear the read and write streams.

Helper to create a skill directory with SKILL.md.

Extract raw finish_reason and response_id from an Anthropic ``Message`` / ``BetaMessage``. Anthropic exposes ``stop_reason`` (e.g. ``"

Extract token usage and response metadata from OpenAI ChatCompletion.

Extract token usage and response metadata from Responses API response.

Extract token usage and response metadata from Gemini response.

Fetch MCP server configurations via CrewAI+ API. Sends a GET request to the CrewAI+ mcps/configs endpoint with comma-separated slugs.

Format messages for Azure AI Inference API. Args: messages: Input messages Returns: List of dict objects wit

Get or create the OpenAI client.

Get the appropriate client - instance-specific or global.

Get the appropriate purpose for a file based on content type. OpenAI Files API requires different purposes for different file types: - Images

Platform-appropriate per-user credential directory (mode 0o700).

Handles the Crew planning.

Initialize backend batch and send collected events.

Type guard to check if the client is an asynchronous AsyncQdrantClient. Args: client: The client to check. Returns: True if

Type guard to check if the client is an asynchronous AsyncClientAPI. Args: client: The client to check. Returns: True if the

Whether a 404 means the model exists but isn't on chat completions. OpenAI distinguishes the two 404s it returns here: responses

Type guard to check if the client is a synchronous QdrantClient. Args: client: The client to check. Returns: True if the cli

Type guard to check if the client is a synchronous ClientAPI. Args: client: The client to check. Returns: True if the client

Return true for complete Anthropic tool-use blocks across SDK shapes. New/preview Anthropic models can return content blocks whose concrete SDK

Create a mock MCPClient that returns *tool_definitions*.

True when a crew runs inside a flow session (context or batch ownership).

Parse an AMP reference into *(slug, optional tool name)*. Accepts both bare slugs (``"notion"``, ``"notion#search"``) and the legacy

Parse the LLM response into a StepObservation. The LLM may return: - A StepObservation instance directly (streaming + litellm path)

Read raw bytes from a secure file, or None if absent.

Subclass must implement: transform validated params dict into API request params.

Return the bound ``Memory`` or raise a clear error if missing.

Coerce a checkpoint field value. Returns: CheckpointConfig — use this config. _SENTINEL — explicit opt-out (``False``), stop walk

Whether this kickoff should defer final flow trace finalization.

Emit agent execution event. Args: formatted_answer: Agent's response to log.

Build an in-memory tar archive via `build(tf)` and return it for reading.

Extract timestamp from checkpoint ID or filename.

Use trained data for the agent task prompt to improve output.

Download a template and copy it into the current working directory. Args: name: Template name (with or without the template_ pref

Add usage metrics from another UsageMetrics object. Args: usage_metrics: The usage metrics to add.

Call the LLM asynchronously and return the response. Args: llm: The LLM instance to call. messages: The messages to send to the L

Get an existing collection or create it if it doesn't exist asynchronously. Keyword Args: collection_name: Name of the collection

Cancel an A2A task. Publishes a cancel event that the cancellable decorator listens for. Args: context: The A2A request context cont

Split a PDF into chunks of maximum page count. Yields chunks one at a time to minimize memory usage. Args: file: The PDF file to chu

Clear all registered global after_tool_call hooks. Returns: Number of hooks that were cleared Example: >>> register_after_to

Build the attributes every span carries, once per process. Cached because it reads the project's ``pyproject.toml``, and because a process ca

Creates the Content Crew

Build the default flow persistence backend. Returns the result of the registered factory if one is set, otherwise a built-in :class:`~crewai.

Execute a tool and check if the result should be treated as a final answer. This function integrates tool hooks for before and after tool executi

Execute crew with trigger payload.

Create a gRPC channel for the given URL.

Build a :class:`ToolFailure` from an exception a tool raised.

Return a path label that does not expose absolute directory prefixes.

Format text as a content block for the LLM. Default implementation uses OpenAI/Anthropic format. Subclasses should override for provi

Get A2A agent configs and response model. Args: a2a_config: A2A configuration (any type). Returns: Tuple of client A2A confi

Get the dimensions of an image file. Args: file: The image file to measure. Returns: Tuple of (width, height) in pixels, or

Return the latest non-yanked PyPI version of CrewAI, or ``None`` on failure.

Call the LLM and return the response, handling any invalid responses. Args: llm: The LLM instance to call. messages: The messages

Get all pending todos. Returns: List of pending TodoItem objects.

Get the current human input provider. Returns: The current provider, or a new SyncHumanInputProvider if none set.