Track token usage internally in the LLM instance. Args: usage_data: Token usage data from the API response

Validate the search query to ensure it's safe to execute. Only SELECT and SHOW statements are allowed for security reasons. Args:

Cancel streaming and clean up resources.

Add content to the knowledge base.

Start an execution context unless one is already active. The outermost crew or flow receives a new uuid by default. Nested executions inherit

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

Creates a deep copy of the Crew instance. Returns: Crew: A new instance with copied components

Delete a collection and all its data. Keyword Args: collection_name: Name of the collection to delete. Raises:

Detect MIME type from file content. Uses python-magic if available for accurate content-based detection, falls back to mimetypes module using

Force additionalProperties=false on all object-type dicts recursively. OpenAI strict mode requires all objects to have additionalProperties=false

Format skill information for agent prompt injection. At METADATA level: returns name and description only. At INSTRUCTIONS level or above: re

Build an expression with the standard Flow runtime context.

Generate a UUID-based filename with extension from content type. Args: content_type: MIME type to derive extension from. Returns:

Get merged crew and task files. Task files override crew files with the same name. Args: crew_id: Unique identifier for the crew exe

Get the current crew context from OpenTelemetry baggage. Returns: CrewContext instance containing crew context information, or None if no

Return the generated-project dependency for CrewAI with tools.

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

Extract tool call streaming events from mock emit calls.

Get the ID of the event that triggered the current execution. Returns: The event_id of the triggering event, or None if not in a triggere

Check if this cached upload has expired.

Normalize a scope path by removing double slashes and ensuring proper format. Args: path: The raw scope path (e.g. '/crew/MyCrewName//age

Parse '@org/skill-name' into (org, name), ignoring any version pin. Retained for backwards compatibility. Use :func:`parse_skill_ref` to read

Read a TOML file from disk and return its parsed contents.

Recall relevant memories. Delegates to this flow's memory. Args: query: Natural language query. **kwargs: Passed to m

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

Recursively resolve all local $refs in the given JSON Schema using $defs as the source. This is needed because Pydantic generates $ref-based sche

Set the platform integration token in the current context. Args: integration_token: The integration token to set.

Strip JSONC comments and trailing commas while preserving string values.

Remove format annotations that OpenAI strict mode doesn't support. OpenAI only supports: date-time, date, time, duration. Other formats like

Check if the model supports function calling. Note: This method is only used by the litellm fallback path. Native providers override

Check if the model supports stop words. Note: This method is only used by the litellm fallback path. Native providers override this m

Collect the failures of one execution, isolated from concurrent ones. An agent may be shared by tasks running concurrently, so accumulating on

Get all available agent tools

Support instance methods by implementing the descriptor protocol. Args: obj: The instance that the method is accessed through.

Write content to a secure file via tempfile + os.replace.

Build a Qdrant Filter for scope prefix matching.

Call OpenAI Chat Completions API. Falls back to the Responses API when the model turns out not to be served by chat completions, whic

Create a skill directory containing a minimal SKILL.md.

Which OpenAI API to actually use for this model. Honours an explicit ``api`` setting, but upgrades to ``"responses"`` for models alre

Lazy-load litellm on first use. Returns True if available.

Execute a single native tool call and return metadata/result.

Extract content between <summary></summary> tags. Falls back to the full text if no tags are found. Args: text: Text potentially con

Apply skill context, tool preparation, and training data to the task prompt. Args: task_prompt: The task prompt after memory and

Initialize backend batch and send collected events.

Install *client* the way a hosted runtime does.

True when ``ALLOW_UNSAFE_PATHS`` is set and ``FORCE_SAFE_PATHS`` is not.

Check if a file is a SQLite database by reading its magic bytes.

Build a CrewAgentExecutor with minimal deps.

Create a minimal CrewAgentExecutor with mocked dependencies.

Merge new tools into existing tools list, avoiding duplicates.

Parse checkpoint JSON into metadata dict.

Show rich panel and prompt for input. Args: crew: The crew instance for context. Returns: User input string

Rewrite ``crewai[extras]==old`` pins in a shell command string. Splits on the known ``crewai[`` prefix and reconstructs the pin with the new

Resolve refs against a temp cwd and cache, with *api* as the registry.

Execute the search query against the SingleStore database. Args: search_query: The SQL query to execute **kwargs: Add

Run a coroutine synchronously, handling nested event loops. If called from within a running event loop, runs the coroutine in a separate thre

Path-traversal-safe extraction for Python versions without tar filters. Validates both the member's own path and, for symlink/hardlink members,

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

Scroll all points matching a filter from a shard.

Submit a save operation to the background thread pool. The future is tracked so that ``drain_writes()`` can wait for it. If the pool

Build a parent/child tree: crew_start ├── task_start │ ├── agent_start │ └── agent_complete (started=agent_start)

Validates table and column names to prevent SQL injection. Simple identifiers must start with a letter and contain only letters, digi

Record an agent result, optionally making it visible to the user.

Handle checkpoint config for a kickoff method. If *from_checkpoint* carries a ``restore_from`` path, builds and returns a restored instance (

Return ``os.environ`` augmented with UV_INDEX_* credentials for every private index referenced under ``[tool.uv.sources]`` in ``pyproject.toml``.

Return the bytes of a one-page PDF containing *text*.

Serialize a module-level callable as a ``"module.qualname"`` string. Args: fn: The callable to serialize. Returns: The dotte

Compute a weighted composite relevance score from semantic, recency, and importance. composite = w_semantic * semantic + w_recency * decay + w_im

Creates a ChromaDB client from configuration.

Create a standardized panel with consistent styling.

Create a minimal valid PDF for testing.

Return the path for SQLite database / app-data storage. Creates the directory if it does not exist.

Deploy a crew using either UUID or project name. Args: uuid (Optional[str]): The UUID of the crew to deploy.

End an execution context owned by the current kickoff. Nested kickoffs pass ``None`` and leave the outer uuid in place.

Evaluate this value as a full CEL expression.

Execute an A2A task using a CrewAI agent. Args: agent: The CrewAI agent to execute the task. context: The A2A request context con

Fork a Crew from a checkpoint, creating a new execution branch. Args: config: Checkpoint configuration with ``restore_from`` set.