Submit a save operation to the background thread pool. The future is tracked so that ``drain_writes()`` can wait for it. If the pool

Build a parent/child tree: crew_start ├── task_start │ ├── agent_start │ └── agent_complete (started=agent_start)

Validates table and column names to prevent SQL injection. Simple identifiers must start with a letter and contain only letters, digi

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

Handle checkpoint config for a kickoff method. If *from_checkpoint* carries a ``restore_from`` path, builds and returns a restored instance (

Return ``os.environ`` augmented with UV_INDEX_* credentials for every private index referenced under ``[tool.uv.sources]`` in ``pyproject.toml``.

Return the bytes of a one-page PDF containing *text*.

Serialize a module-level callable as a ``"module.qualname"`` string. Args: fn: The callable to serialize. Returns: The dotte

Clear all global hooks across every interception point.

Set span status to ERROR and end it. Used for spans representing work that failed, so failures are distinguishable from successes downstream.

Build the attributes every span carries, once per process. Cached because it reads the project's ``pyproject.toml``, and because a process ca

Compute a weighted composite relevance score from semantic, recency, and importance. composite = w_semantic * semantic + w_recency * decay + w_im

Establish HTTP connection to MCP server. Returns: Self for method chaining. Raises: MCPConnectionError: If t

Creates a ChromaDB client from configuration.

Records creating a new crew deployment (``crewai deploy create``). Also emits ``deploy:created`` so that deployments are countable from the

Create a standardized panel with consistent styling.

Create a minimal valid PDF for testing.

Return the path for SQLite database / app-data storage. Creates the directory if it does not exist.

Deploy a crew using either UUID or project name. Args: uuid (Optional[str]): The UUID of the crew to deploy.

End an execution context owned by the current kickoff. Nested kickoffs pass ``None`` and leave the outer uuid in place.

Evaluate this value as a full CEL expression.

Execute an A2A task using a CrewAI agent. Args: agent: The CrewAI agent to execute the task. context: The A2A request context con

Fork a Crew from a checkpoint, creating a new execution branch. Args: config: Checkpoint configuration with ``restore_from`` set.

Get or create a page for the specified thread.

Call the LLM and return the response, handling any invalid responses. Args: llm: The LLM instance to call. messages: The messages

Get or create a page for the specified thread.

Return the access token if valid and not expired, else None.

Get Gemini file uploader.

Handle context length exceeded by either summarizing or raising an error. Args: respect_context_window: Whether to respect context window

Handle the completion flow as shown in your diagram.

Pydantic-compatible function to import a class/function from a string path. Args: v: Import path string in the format 'module.path.ClassN

Check if batch is initialized

Return ``(is_newer, current_version, latest_version)``.

List records in a scope, newest first. Args: scope: Optional scope path prefix to filter by. If None and root_scope

Load state and pending feedback context. Args: flow_uuid: Unique identifier for the flow instance Returns: T

Load one skill input into Skill objects. Accepts a pre-loaded Skill object, skill search path, inline SKILL.md string, or '@org/name' registr

Mark a todo as running by step number.

Memoize a method by caching its results based on arguments. Handles both sync and async methods. Pydantic BaseModel instances are converted t

Parse a ``--inputs`` JSON object, exiting with a pointed error if invalid.

Query across all knowledge sources to find the most relevant information. Returns the top_k most relevant chunks. Raises:

Raise a typed MCP connection error when an HTTP status is known. Args: message: Fallback message when no HTTP status can be recovered.

Register an event handler for a specific event type. Args: event_type: The event class to listen for handler: The han

Render the tool name, description, and args in plain text. search: This tool is used for search, args: {"query": {"type": "string"}} calculat

Save the access token and its expiration time. Args: access_token: The access token to save. expires_at: The UNIX tim

Mark telemetry live (idempotent). Deliberately does not install a global TracerProvider. Doing so made every OTel-instrumented librar

Set the ID of the triggering event for causal chain tracking. Args: event_id: The event_id that triggered the current execution, or None.

Return a portable Markdown skill for authoring Flow declarations.

Store files for a crew execution. Args: execution_id: Unique identifier for the crew execution. files: Dictionary mapping names t

Iterate over frames, optionally filtered by channel.

Context manager to suppress all warnings. Yields: None during the context execution. Note: This implementation consolidates

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

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

Update the [project] version field in a pyproject.toml file. Args: file_path: Path to pyproject.toml file. new_version: New versi

Validate JSON crew structure without kicking off the crew.

Import and return the class/function from the import path. Args: v: Import path string in the format 'module.path.ClassName'. Return

Print a yellow deprecation warning for a legacy CLI command or flag.

Create an agent with explicitly activated, always-on skills.

Raise if a connected socket's peer is a private/reserved address.

Add A2A delegation instructions to prompt. Args: a2a_agents: Dictionary of A2A agent configurations task_description: Original ta

Build an UploadResult for a completed upload. Args: file_id: The uploaded file ID. content_type: The file's content t

Convert contents to dict format.

Helper to create a skill directory with SKILL.md.

Route labels the framework handles, from the definition when there is one. Shared with ``route_turn`` so both agree on what counts as a custo

Extract raw finish_reason and response_id from an Anthropic ``Message`` / ``BetaMessage``. Anthropic exposes ``stop_reason`` (e.g. ``"

Extract token usage and response metadata from OpenAI ChatCompletion.

Extract token usage and response metadata from Responses API response.

Extract token usage and response metadata from Gemini response.

Fetch MCP server configurations via CrewAI+ API. Sends a GET request to the CrewAI+ mcps/configs endpoint with comma-separated slugs.

Send batch finalization to backend Args: events_count: Number of events that were successfully sent

Format messages for Azure AI Inference API. Args: messages: Input messages Returns: List of dict objects wit

Format messages for Gemini API. Gemini has specific requirements: - System messages are separate system_instruction - Content

Get or create the OpenAI client.

Get the appropriate client - instance-specific or global.

Get the appropriate purpose for a file based on content type. OpenAI Files API requires different purposes for different file types: - Images

Platform-appropriate per-user credential directory (mode 0o700).