Write content to a secure file via tempfile + os.replace.

Build a Qdrant Filter for scope prefix matching.

Call OpenAI Chat Completions API. Falls back to the Responses API when the model turns out not to be served by chat completions, whic

Which OpenAI API to actually use for this model. Honours an explicit ``api`` setting, but upgrades to ``"responses"`` for models alre

Lazy-load litellm on first use. Returns True if available.

Execute a single native tool call and return metadata/result.

Extract content between <summary></summary> tags. Falls back to the full text if no tags are found. Args: text: Text potentially con

Apply skill context, tool preparation, and training data to the task prompt. Args: task_prompt: The task prompt after memory and

Install *client* the way a hosted runtime does.

Check if a file is a SQLite database by reading its magic bytes.

Build a CrewAgentExecutor with minimal deps.

Create a minimal CrewAgentExecutor with mocked dependencies.

Merge new tools into existing tools list, avoiding duplicates.

Parse checkpoint JSON into metadata dict.

Show rich panel and prompt for input. Args: crew: The crew instance for context. Returns: User input string

Rewrite ``crewai[extras]==old`` pins in a shell command string. Splits on the known ``crewai[`` prefix and reconstructs the pin with the new

Resolve refs against a temp cwd and cache, with *api* as the registry.

Execute the search query against the SingleStore database. Args: search_query: The SQL query to execute **kwargs: Add

Run a coroutine synchronously, handling nested event loops. If called from within a running event loop, runs the coroutine in a separate thre

Path-traversal-safe extraction for Python versions without tar filters. Validates both the member's own path and, for symlink/hardlink members,

Save the documents to the storage. This method should be called after the chunks and embeddings are generated. Raises: V

Scroll all points matching a filter from a shard.

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)

Add a tool result to the cache. Args: tool: Name of the tool. input: Input string used for the tool. outp

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

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

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

Create an agent executor for the agent. Returns: An instance of the CrewAgentExecutor class.

Creates a ChromaDB client from configuration.

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.

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

Emit a final ``FlowFinishedEvent`` and finalize the trace batch. Pairs with ``flow.defer_trace_finalization = True`` (or ``Conversati

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

Format skill information for agent prompt injection. At METADATA level: returns name and description only. At INSTRUCTIONS level or above: re

Get or create a page for the specified thread.

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

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

Load the most recent state for a given flow UUID. Args: flow_uuid: Unique identifier for the flow instance Returns:

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.

Read a TOML file from disk and return its parsed contents.

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

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

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 crew execution. Args: execution_id: Unique identifier for the crew execution. files: Dictionary mapping names t

Iterate over frames, optionally filtered by channel.

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

Factory function that returns crewai platform tools. Args: apps: List of platform apps to get tools that are available on the platform.

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

Clear the read and write streams.

Create a skill directory containing a minimal SKILL.md.

Helper to create a skill directory with SKILL.md.