Store files for a crew execution asynchronously. Args: execution_id: Unique identifier for the crew execution. files: Dictionary

Rebind the runtime ``Memory`` dependency after restore. Required after deserializing from a checkpoint, since the live ``Memory`` can

Return a copy of ``os.environ`` augmented with UV_INDEX_* credentials for ``repository_handle``. The handle is normalized to upper-case with

Build an execution plan from handlers and their dependencies. Args: handlers: All handlers for an event type dependencies: Mappin

Build instructions for downgrading native tools to text tool calls.

Calculates and returns the usage metrics.

Call Azure AI Inference API. Args: messages: Input messages tools: List of tool/function definitions call

Mock LLM call that returns a predefined response. Properly formats messages to match OpenAI's expected structure.

Execute LLM call with hooks and parse the response. Returns routing decision based on parsing result.

Override the stop list for ``llm`` within the current call scope. Only ``llm``'s reads via :attr:`BaseLLM.stop_sequences` see ``stop``; other

Call a tool on the MCP server. Args: tool_name: Name of the tool to call. arguments: Tool arguments. Returns

Check if an output type is set.

Chunk the input text into smaller pieces. Args: text: The text to chunk. Returns: A list of text chunks.

Map user text to one of the given outcomes using an LLM.

Compute a collision-resistant key using SHA-256.

Compute the SHA-256 hash of the given content. Args: content: The content to hash. Returns: The SHA-256 hash of the content as a

Configure HTTP client with auth-specific settings. Only HTTPDigestAuth and APIKeyAuth need client configuration. Args: auth: Authent

Copy a file from src to dst.

Create an async chunk generator that uses a holder to access streaming output. Args: state: The streaming state. run_coro: Corout

Create a new crew deployment. Args: confirm (bool): Whether to skip the interactive confirmation prompt. ski

Create a scoped synchronous public frame generator.

Create Recall and Remember tools for the given memory instance. When memory is read-only (``_read_only=True``), only the RecallMemoryTool is

Create and register streaming state. Args: current_task_info: Task context info. result_holder: List to hold the final result.

Return the per-call usage accrued since ``baseline`` was captured. Both objects must come from the same monotonically increasing accu

Return all descendant nodes, children recursively. Args: event_id: The root event ID to start from. Returns:

Generate embeddings for multiple texts. Args: texts: List of texts to embed Returns: List of embedd

Embed multiple texts in a single API call. The embedder already accepts ``list[str]``, so this just calls it once with the full batch and nor

Enable streaming on all agents that have an LLM configured. Args: agents: Iterable of agents to enable streaming on.

Enable cursor movement/history editing for Click text prompts when available.

Evaluate the training data based on the llm output, human feedback, and improved output. Args: - training_data: The trai

Execute the task asynchronously.

Execute native tool calls in a batch. Processes all tools from pending_tool_calls, executes them, and appends results to the conversa

Extract conversation states from all registered extensions. Args: conversation_history: The sequence of A2A messages exchanged.

Extract common parameters from handler kwargs. Args: kwargs: Handler kwargs dict. Returns: CommonParams with extracted value

Extract the checkpoint ID from a file path. The filename format is ``{ts}_{uuid8}_p-{parent}.json``. The checkpoint ID is the ``{ts}_

Extract discrete memories from a raw content blob using the LLM. This is a pure helper -- it does NOT store anything. Call remember()

Find all __init__.py files that contain __version__. Args: base_path: Base directory to search in. Returns: List of paths to

Sync local shard records to the central shard.

Format native tool output when a tool explicitly defines a formatter.

Build an ``Oauth2Settings`` instance from the persisted CrewAI settings.

Create multiple MergeAgentHandlerTool instances from a Tool Pack. Args: tool_pack_id: UUID of the Tool Pack

Generate an input description using AI based on the context of the crew. Args: input_name: The name of the input placeholder. cre

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

Get the parent of the current scope (stack[-2]).

Get the enterprise API base URL from environment or use default.

Get information about an uploaded file. Args: file_id: The file identifier. Returns: Dictionary with file in

Retrieve files for a crew execution. Args: execution_id: Unique identifier for the crew execution. Returns: Dictionary of fi

Get all packages from lib/ directory. Args: lib_dir: Path to lib/ directory. Returns: List of package directory paths.

Get the platform API base URL from environment or use default.

Core logic for handling agent actions and tool results. Args: formatted_answer: The agent's action tool_result: The result of exe

Public method for the planning process that creates and refines a plan for the task until the agent is ready to execute it. Returns:

Handle lite agent execution events with panel display.

Handle LLM stream chunk event - display streaming text in a panel. Args: chunk: The new chunk of text received. accum

Increment the delegations counter.

Initialize a Git repository when Git is available.

Inject A2A server methods onto an Agent instance. Adds a `to_agent_card(url: str) -> AgentCard` method to the agent that generates an A2A-com

Install the crew by running the UV command to lock and install.

Interpolate inputs into the task description, expected output, and output file path. Add conversation history if present. Args:

Execute agent asynchronously with given inputs. This method is designed for use within async contexts, such as when the agent is call

Check if this extension is active for the current request. An extension is active if the client declared support for it. Args:

Check if the object carries Flow method wrapper metadata.

Check if Git is installed and available in the system.

Prompt only in an interactive terminal, never in non-interactive mode.

Return True if the current context is dispatching a replayed event. Listeners with side effects (checkpoint writes, external API calls that s

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

Show locally installed skills.

List all available crews.

List all uploaded files. Returns: List of dictionaries with file information.

List available tools from MCP server. Args: use_cache: Whether to use cached results. If None, uses client's cach

Load a JSON or JSONC file.