Clear files for a task execution. Args: task_id: Unique identifier for the task.

Record that the response was closed.

Return a configured CrewAI definition path for a project type. ``[tool.crewai].type`` must match ``project_type`` and ``definition`` must be

Every message body sent under ``role`` across all calls.

Convert a path to a Path object.

Create a converter instance based on the agent or provided class. Args: agent: The agent instance. converter_cls: The converter c

Create ``branch`` from current HEAD, resetting any stale copy. If the branch exists locally or on origin, prompts the user to choose between

Records that a crew deployment was confirmed created, with its uuid. Distinct from :meth:`create_crew_deployment_span`, which fires *before*

The machine's core count as a coarse band, never the exact number. Answers "is this a server or someone's laptop", which ``runtime_context``

Return the failure a tool declared, if it declared one. Only an explicit :class:`ToolFailure` counts, so a tool legitimately returning text a

Generate embedding for a single text. Args: text: Text to embed Returns: List of floats representin

Ensure all schema objects in anyOf/oneOf have a 'type' key. OpenAI strict mode requires every schema to have a 'type' key. Empty schemas {} i

Extract ``(finish_reason, response_id)`` from a choices-shaped response. Handles both object-style (``response.id``, ``response.choices[0].finish

Extract the checkpoint ID from a location string. Args: location: The identifier returned by a previous ``checkpoint`` call.

Extract knowledge from the task prompt.

Records that a feature was used. One span = one count.

Fetch latest updates from the remote.

Build the (body, content_type, final_url) tuple safe_get_bounded returns.

Format an error message with the given template and error. Args: template: The error message template to use error: T

Sync wrapper for aget_all_for_provider.

Return the saved authentication token; raise ``AuthError`` if missing.

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

Return the normalized ``[tool.crewai]`` table from pyproject data.

Get the ID of the last emitted event for linear chain tracking. Returns: The event_id of the previously emitted event, or None if no even

Get an existing collection or create it if it doesn't exist. Returns existing collection if found, otherwise creates a new one. Keyw

Get the page count of a PDF file. Args: file: The PDF file to measure. Returns: Number of pages, or None if page count canno

Get all todos that are ready to execute (pending with satisfied dependencies). Returns: List of TodoItem objects that can be exec

Get the sanitized names of the tools. Args: tools: List of tools to get names from. Returns: Comma-separated string of sanit

Show method status panel.

Execute the agent with the given messages. Args: messages: Either a string query or a list of message dictionaries.

Start the flow execution asynchronously. This method performs state restoration (if an 'id' is provided and persistence is available)

List immediate child scopes under path. Args: path: Scope path to list children of. If None and root_scope is set,

Acquire a named lock, yielding while it is held. Args: name: A human-readable lock name (e.g. ``"chromadb_init"``). The bui

Entry point for the CLI.

Concatenate failure lists, dropping records already present. Guardrail retries rebuild the output from overlapping sources, so identity is no

Record a tool usage event in the current trace. Args: tool_name: Name of the tool used. tool_args: Arguments passed t

Optimize an image to fit within a target file size. Uses iterative quality reduction to achieve target size. Args: file: The image f

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

Process the LLM response and format it into an AgentAction or AgentFinish. Args: answer: The raw response from the LLM use_stop_w

Process response through all registered extensions. Args: agent_response: The parsed agent response. extension_states

Process A2A task state and return result dictionary. Shared logic for both polling and streaming handlers. Args: a2a_task: The A2A t

The tool_name the code under test handed to telemetry.

Request user input via console (blocking). Displays the prompt message with formatting and waits for the user to type their response.

Clear all stored task outputs.

Return ``response``, awaiting it first when the client is async. Args: response: A response, or an awaitable resolving to one. Retur

Return the Python symbol named by a project definition field.

Set reference to batch manager for sending events. Args: batch_manager: The trace batch manager instance.

Bind an execution uuid for the current context. Use this from enterprise / hosts that already own the run id (e.g. Celery ``kickoff_id``). Ov

Determine if tracing should be enabled. This is the single source of truth for tracing enablement. Priority order: 1. Explicit override (

Check if tracing messages should be suppressed. Returns: True if messages should be suppressed, False otherwise.

Gracefully shutdown the event loop and wait for all tasks to finish. Args: wait: If True, wait for all pending tasks to complete

Store files for a task execution. Args: task_id: Unique identifier for the task. files: Dictionary mapping names to file inputs.

Remove null type from anyOf/type arrays. Pydantic generates `T | None` for optional fields, which creates schemas with null in the type. Howe

Serialize this LLM to a dict that can reconstruct it via ``LLM(**config)``. Returns the core fields that BaseLLM owns. Provider subclasses sh

The 400 OpenAI returns for tools + reasoning_effort.

Train the crew by running a command in the UV environment. Args: n_iterations (int): The number of iterations to train the crew.

Context manager to set the triggering event ID for causal chain tracking. All events emitted within this context will have their triggered_by_eve

Update an existing task output in storage. Args: task_index: The index of the task to update. log: Dictionary contain

Validate a file against provider constraints. Args: file: The file to validate. Returns: List of validation

Validate that a directory path is safe to read. Same as :func:`validate_file_path` but also checks that the path is an existing directory.

Validate a file against provider constraints. Dispatches to the appropriate validator based on file type. Args: file: The file to va

Validate an image file against constraints. Args: file: The image file to validate. constraints: Image constraints to validate ag

Asynchronously call provided async handlers. Args: source: The object that emitted the event event: The event instanc

Executes tasks using native async and returns the final output. Args: tasks: List of tasks to execute start_index: In

Add message to conversation history. Args: text: Message content. role: Message role (default: assistant).

Build an EdgeConfig for the given vector dimensionality.

Build an S3 URI from a key. Args: key: The S3 object key. Returns: S3 URI string.

Atomically check max usage and increment the counter. Returns: None if usage was claimed, otherwise a :class:`ToolFailure`. A

Convert tools to a format that can be used for interference. Args: tools: List of tools to convert. Returns:

Copy metadata from original function to wrapper. Args: wrapper: The wrapper object to copy metadata to original: The original fun

Create a copy of the current state. Returns: A copy of the current state

Create a hook decorator with filtering support. This factory function eliminates code duplication across the four hook decorators. Args:

Helper to create mock plan response.

Creates a summary of all tasks. Returns: A string summarizing all tasks with their details.

Delegate to A2A agent with multi-turn conversation support. Args: self: The agent instance agent_response: The AgentResponse indi

Build the deployment show URL, resolving UUID-only responses if needed.

Dispatch ``point`` unless this flow must not expose it. Returns whether the dispatch happened, so callers can keep the EXECUTION_STAR

Display deployment information. Args: json_response (Dict[str, Any]): The deployment information to display.