Add an edge from this node to another. Args: edge_type: The relationship type. target_id: The event_id of the target

Async delete an uploaded file. Default implementation runs sync delete in executor. Override in subclasses for native async support.

Get a cached upload by file hash. Args: file_hash: Hash of the file content. provider: The provider name. Re

Retrieve files for a crew execution asynchronously. Args: execution_id: Unique identifier for the crew execution. Returns: D

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

Append a message to ``state.messages`` or the flow fallback buffer.

Write an ExecutionContext back into the ContextVars.

Save documents to the knowledge base asynchronously. Args: documents: List of document strings to save.

Search for documents in the knowledge base asynchronously. Args: query: List of query strings. limit: Maximum number

Cache an uploaded file by hash. Args: file_hash: Hash of the file content. content_type: MIME type of the file.

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

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.

Clear all global hooks across every interception point.

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 a loader tool when metadata-only skills are available. Args: skills: Skills configured on the agent. source: Event source

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:

Show flow status panel.

Handle lite agent execution events with panel display.