GET a URL while validating each redirect target before following it.

Invoke after_llm_call hooks for direct LLM calls (no agent context). This method should be called by native provider implementations after

Replace crewai dependency version pins in a pyproject.toml string. Handles both pinned (==) and minimum (>=) version specifiers, as well as e

Add documents with their embeddings to a collection asynchronously. Keyword Args: collection_name: The name of the collection to

Create a deployable ZIP archive for a CrewAI project.

Finalize batch and return it for sending

Get current call_id from context

Handle unknown errors by informing the user. Args: printer: Printer instance for output exception: The exception that occurred

List all CLI configuration parameters.

Context manager that establishes an LLM call scope with a unique call_id.

Load and process all files from a directory recursively. Args: source_content: Directory path or URL to a directory listing

Load a skill at METADATA disclosure level. Parses SKILL.md frontmatter only and validates directory name. Args: skill_dir: Path to t

Split SKILL.md content into frontmatter dict and body text. Args: content: Raw SKILL.md file content. Returns: Tuple of (fro

Fetch content from URL (for providers that don't support URL references).

Resume Live session updates after human input is complete. New streaming sessions will be created on-demand when needed. This method

Convert to JSON-RPC error object format.

Generate structured output using the specified Pydantic model. Returns: Instance of the specified Pydantic model with structured

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

Resolve tool specs into tool instances or serialized BaseTool dicts. Strings keep the existing shorthand behavior. Dicts are passed through so

Process input text synchronously.

Add a new task output to storage. Args: task: The task that was executed. output: The output produced by the task.

Create a minimal valid PNG for testing.

Delete an uploaded file. Args: file_id: The file identifier to delete. Returns: True if deletion was success

Execute *sql_query* and return the results as a list of dicts. Parameters ---------- sql_query: The SQL statement

Create a Fingerprint from a dictionary representation. Args: data: Dictionary representation of a fingerprint Returns:

Get all registered global after_llm_call hooks. Returns: List of registered after hooks

Context manager to temporarily set the platform integration token. Args: integration_token: The integration token to set within the context

Replay the crew execution from a specific task.

Import a module, optionally returning a specific attribute. Args: name: The module name to import. purpose: Description of what r

Execute the crew and capture the result.

Validate a video file against constraints. Args: file: The video file to validate. constraints: Video constraints to validate aga

Create a simple analyst crew for file analysis.

Create a batch slice from prepared documents. Args: prepared: PreparedDocuments containing ids, texts, and metadatas. start_index

Emit stream chunk event. Args: chunk: The text content of the chunk. from_task: The task that initiated the call.

LiteLLM responses/chunks share the choices-shape with OpenAI/Azure; delegate to the shared extractor.

Find the CheckpointConfig for an event source. Walks known relationships: Task -> Agent -> Crew. Flow and Agent carry their own checkpoint fi

Apply the executor's stop words to the LLM for the duration of one call. Uses :func:`crewai.llms.base_llm.call_stop_override` so the LLM's stop

Save task result to unified memory (memory or crew._memory).

Show version update message if a newer version is available. Only displays when verbose mode is enabled and not running in CI/CD.

Validate and parse structured output. Args: response: Raw response string response_format: Optional Pydantic model fo

Add a new task output record to the database. Args: task: The Task object containing task details. output: Dictionary

Build a comprehensive field description including constraints. Embeds format, enum, pattern, min/max, and example constraints into the descri

Convert a result to a Pydantic model or JSON. Args: result: The result to convert. Usually a JSON string, but a Pydantic inst

Enforce the requests per minute (RPM) limit if applicable. Args: request_within_rpm_limit: Function to enforce RPM limit.

Freeze the current Edge into ``docs/v<version>/`` and update docs.json. Args: version: Release version as ``"X.Y.Z"`` (no leading ``v``).

Convert MCP server references/configs to CrewAI tools. Delegates to :class:`~crewai.mcp.tool_resolver.MCPToolResolver`.

Increment the tools errors counter.

Executes the Crew's workflow for each input and aggregates results. Args: inputs: List of input dictionaries, one per execution.

Parse tool call arguments from a JSON string or dict. Returns: ``(args_dict, None)`` on success, or ``(None, error_result)`` on J

Retrieve relevant memories. ``shallow`` embeds the query directly and runs a single vector search. ``deep`` (default) uses the Recall

Reset specific or all memories for the crew. Args: command_type: Type of memory to reset. Valid options: 'memory'

Search for similar documents using a query. Keyword Args: collection_name: Name of the collection to search in. query

Set available input files. Args: files: Dictionary mapping file names to file inputs.

Get the git status in porcelain format.

Allow arbitrary attribute assignment for backward compat with plain class.

Save the documents to the storage asynchronously. This method should be called after the chunks and embeddings are generated. Raises

Build a minimal docs/ tree with one previous snapshot + Edge + docs.json. The shape mirrors the real repo: an Edge directory with per-locale fold

Turn a raw import-time exception into a user-actionable finding.

Collapse free-form feedback to a predefined outcome using LLM. This method uses the specified LLM to interpret the human's feedback a

Extract token usage and response metadata from Anthropic response.

Format messages with role labels for summarization. Skips system messages. Handles None content, tool_calls, and multimodal content blocks.

Get or create a code interpreter for the specified thread. Args: thread_id: Thread ID for the code interpreter session R

Return ``True`` if *fn* cannot survive a serialize/deserialize round-trip. Built-in functions, plain module-level functions, and classes produce

Read the user-data JSON file, returning ``{}`` on missing/corrupt.

Prepare documents for ChromaDB by extracting IDs, texts, and metadata. Args: documents: List of BaseRecord documents to prepare. Ret

Run an async coroutine from sync context without blocking event loop.

Run a void telemetry procedure, swallowing failures.

Set status for an explicit plan step reported by the planner.

Asynchronously emit an event to registered async handlers. Only processes async handlers. Use in async contexts. Args: s

Clean up Stagehand resources.

Kill the cached persistent sandbox if one exists.

Return the configured declarative flow source for flow projects.

Create a new collection in Qdrant. Keyword Args: collection_name: Name of the collection to create. Must be unique. v