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

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

Execute a task with the agent asynchronously. Args: task: Task to execute. context: Context to execute the task in.

Asynchronously invoke the tool. Args: input: The input arguments config: Optional configuration **kwargs:

Async read the file content as bytes. Raises: TypeError: If the underlying source doesn't support async read.

Render the text the agent sees for this failure.

Run the flow asynchronously and stream scoped public frames.

Call Anthropic messages API. Args: messages: Input messages for the chat completion tools: List of tool/function defi

Check if max iterations reached before proceeding with reasoning.

Write a checkpoint. Args: location: Storage destination. For JsonProvider this is a directory path; for SqlitePro

Write a JSON checkpoint file. Args: data: The serialized JSON string to persist. location: Base directory where check

Classify an exception as transient or permanent upload error. Analyzes the exception type name and status code to determine if the error is l

Sync wrapper for aclear.

Clear all registered global before_tool_call hooks. Returns: Number of hooks that were cleared Example: >>> register_before_

Clear files for a crew execution. Args: execution_id: Unique identifier for the crew execution.

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

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

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

Disconnect from MCP server and cleanup resources.

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.

Extract discrete memories from content. Delegates to this flow's memory. Args: content: Raw text (e.g. task + result dump).

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.

Returns the context window size, using 75% of the maximum to avoid cutting off messages mid-thread. Raises: Valu

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)

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 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

Register a hook scoped to the current :func:`scoped_hooks` context.

Interpolate ``${...}`` expressions inside nested strings as CEL. A string that is exactly one ``${...}`` keeps the evaluated value's

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

Enter an execution-scoped hook registry. Hooks registered inside this context (via :func:`register_scoped`) run after global hooks and are di

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

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 context to a dictionary for persistence. Returns: Dictionary representation suitable for JSON serialization.

Fetch actions and return built tools.

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.