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

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

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.

Return exception details without OS-added absolute path context.

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

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.

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

Records an interception-hook dispatch via Feature Usage. Emits ``hooks:<point>`` on every dispatch, plus ``hooks:aborted`` when a hoo

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

Build a fresh Telemetry without touching the process-wide singleton. Telemetry is a singleton whose __init__ registers atexit and signal hand

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.

Load a vendored A2UI JSON schema by name and version. Args: name: Schema name without extension, e.g. ``"server_to_client"``. ver

Promote a skill to RESOURCES disclosure level. Catalogs available resource directories (scripts, references, assets). Args: skill: S

Observe a step's result and decide on plan continuation. This runs after EVERY step execution — not just failures. Args:

Unregister an event handler for a specific event type. Args: event_type: The event class to stop listening for handle

Decorator to register an event handler for a specific event type. Handlers can accept 2 or 3 arguments: - ``(source, event)`` — s

Arrow-key single-select from plain labels. Returns: Selected index, or ``-1`` if cancelled.

Process multiple files according to constraints. Args: files: Dictionary mapping names to file inputs. Returns:

Stream file content in chunks without loading entirely into memory. Args: chunk_size: Size of each chunk in bytes. Yield

Store one or more items in memory. Pass a single string for synchronous save (returns the MemoryRecord). Pass a list of strings for n

Remember content; scope is relative to this scope's root.

Render a template file using ``{{placeholder}}`` replacements.

Reset the entire backing memory store, ignoring ``root_scope``.

Return the CrewAI AMP client to use, or build ``default``. Hosted runtimes install a client of their own through ``_create_plus_client_hook``

Execute an explicit list of hooks against a context. This is the shared engine used both by :func:`dispatch` (which resolves global + scoped

Sanitize a JSON schema for Anthropic strict tool use.

Persist the flow state after method completion. Args: flow_uuid: Unique identifier for the flow instance method_name:

Search for memories by vector similarity with optional filters. Args: query_embedding: Embedding vector for the query.

Attempt to keep a single set of callbacks in litellm by removing old duplicates and adding new ones. Note: This only affects

Set the emission counter to resume from a given value.

Set the RuntimeState that will be passed to event handlers.

Return True if console output should currently be suppressed.

Append a user message and stream one conversational turn as frames.

Check if the LLM supports stop words. Returns: True if the LLM supports stop words, False otherwise.

Check if the model supports stop words.

Test and evaluate the Crew with the given inputs for n iterations. Uses concurrent.futures for concurrent execution.

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

Convert a list of tools to CrewStructuredTool instances.

Records when a tool usage results in an error. Args: llm: The language model being used when the error occurred. agen

Track delegation if the tool is a delegation tool. Args: tool_name: Name of the tool being executed. tool_args: Arguments passed

Trains the crew for a given number of iterations.

Unregister a specific global after_llm_call hook. Args: hook: The hook function to remove Returns: True if the hook was foun