Return True if *value* looks like a registry reference (@org/name).

Check if a response from the LLM is a list of tool calls. Supports OpenAI, Anthropic, Bedrock, and Gemini formats. Args: response: T

List available templates with an interactive selector to install.

List all available triggers from integrations.

Load all stored task outputs. Returns: List of task output dictionaries, or None if no outputs exist.

Load a ``Crew`` from an in-memory JSON/YAML crew definition.

Load content from a URL. Args: url: The URL to fetch content from kwargs: Additional keyword arguments (can include 'headers' ove

Promote a skill to INSTRUCTIONS disclosure level. Reads the full SKILL.md body text. Args: skill: Skill at METADATA level. Retu

Load skill inputs into de-duplicated Skill objects. Preserves first-seen order when multiple inputs resolve to the same skill name. Registry

Log successful LLM API call and track token usage.

Mark a todo as failed by step number.

Normalize a pyproject project.name into a Python package directory name. Mirrors the rules in ``crewai.cli.create_crew.create_crew`` so the v

Get the Git repository's remote URL.

Parse agent output text into AgentAction or AgentFinish. Expects output to be in one of two formats. If the output signals that an action sh

Read and parse a SKILL.md file. Args: path: Path to the SKILL.md file. Returns: Tuple of (SkillFrontmatter, body text).

Parse tools to be used for the task. Args: tools: List of tools to parse. Returns: List of structured tools. Raises:

Create interactive HTML visualization of Flow structure. Args: filename: Output HTML filename (default: "crewai_flow.html").

Pop an event entry from the scope stack.

Prepare crew for kickoff execution. Handles before callbacks, event emission, task handler reset, input interpolation, task callbacks, agent

Process the guardrail for the agent output. Args: output: The output to validate with the guardrail guardrail: The guardrail to v

Prompt for each name and return ``{name: value}``. ``describe(name)`` returns an optional hint shown dim above the prompt (used by flows to s

Remove old checkpoints, keeping at most *max_keep* per branch. Args: location: The storage destination passed to ``checkpoint``.

Register a cleanup callback on the streaming output. Ensures the event handler is unregistered even if aclose()/close() is called before iter

Request human input during tool hook execution. This method pauses live console updates, displays a prompt to the user, waits for the

Reset all settings to default values.

Return the Python symbol named by a project definition field.

Sanitize tool name for API compatibility.

Sanitize a JSON schema for OpenAI strict function calling.

Return a scoped view of this memory.

Serialize a single guardrail value for JSON checkpointing. String descriptions are preserved; callable references cannot be JSON-serialized a

Serialize a guardrails value (single or sequence) for JSON checkpointing. Dropped callables are filtered out of lists rather than emitted as ``No

Serialize a ``type[BaseModel]`` field value as its JSON schema. Args: value: A ``type[BaseModel]`` subclass, ``None``, or another union m

Install our TracerProvider as the global one (idempotent).

True if we should auto-collect traces for first-time user. Returns: True if first-time user AND telemetry not disabled AND tracing not ex

Return a portable Markdown skill for authoring Flow declarations.

Update crewai dependency versions in CLI template pyproject.toml files. Uses simple string replacement instead of TOML parsing because templa

Validate and convert a JSON string to a Pydantic model or dict. Args: result: The JSON string to validate and convert. model: The

Validate a text file against general constraints. Args: file: The text file to validate. constraints: Provider constraints to val

Wrap a FileSource in the appropriate typed FileInput wrapper. Args: source: The file source to wrap. Returns: Typed FileInpu

Initialize the exception. Args: message: Error message describing the issue. file_name: Optional name of the file tha

Async call to OpenAI Chat Completions API. Falls back to the Responses API for models not served by chat completions, mirroring :meth

Return (sandbox, should_delete_after_use).

Return (sandbox, should_kill_after_use).

Internal async implementation of AgentCard fetching.

Re-run the executor flow asynchronously using feedback messages.

Async cross-process lock that acquires/releases in an executor.

Process pending async tasks and return their outputs.

Update lineage fields after a successful checkpoint write. Sets ``_checkpoint_id`` and ``_parent_id`` so the next write records the c

Check if tool has reached its usage limit. Args: tool: The tool to check tool_name: The name of the tool (used for er

Clear fired OR listeners for cyclic flows.

Collapse unfinished display-only plan steps once the task succeeds.

Compute SHA-256 hash of file content. Uses streaming for FilePath sources to avoid loading large files into memory.

Snapshot the cumulative usage counters backing this agent's LLM. The counters live on the LLM instance (or the agent's token process

Resolve the default checkpoint location. When the caller passes the default directory path, check whether a SQLite database exists at the con

Block until all pending background memory saves have completed. Covers the crew memory, per-agent memories, and the manager agent's m

Tighten a dedicated config directory to 0o700. Skips directories shared with other users or content (the system temp dir and the current work

Register checkpoint handlers on the event bus once, lazily.

Create payload indexes for efficient filtering.

Executes all listeners and routers triggered by a method completion. This internal method manages the execution flow by: 1. First exe

Executes a flow's start method and its triggered listeners. This internal method handles the execution of methods marked with @start

Executes tasks sequentially and returns the final output. Args: tasks (List[Task]): List of tasks to execute manager

ChatCompletion / ChatCompletionChunk share the choices-shape; delegate to the shared extractor.

Azure ``ChatCompletions`` / ``StreamingChatCompletionsUpdate`` share the choices-shape; delegate to the shared extractor.

Extract and format thinking block from content block. Args: content_block: Content block from Anthropic response Returns

Fetch columns for *table_name* using a parameterised query. The table name is bound via SQLAlchemy's ``:param`` syntax to prevent SQL

Parse an OpenAI-shaped ``GET /models`` response.

Filter methods by attribute presence, preserving exact callable types. Args: methods: Dictionary of methods to filter. attribute:

Find JSON objects/arrays in text and pretty-print them.

Format messages for Gemini API. Gemini has specific requirements: - System messages are separate system_instruction - Content

Format messages according to provider requirements. Args: messages: List of message dictionaries with 'role' and 'content' keys.

Format prompt template with input values. Args: prompt: Template string. inputs: Values to substitute. Retur

Convert CrewAI tools to Converse API format following AWS specification.

Generate, display, and optionally edit release notes. Args: version: Version being released. tag_name: Tag name for the release.

Safely gets the agent's backstory, providing a default if not available. Returns: The agent's backstory or a default value.

Parse the click requirement directly from a pyproject.toml file.