Retrieve a tool prompt by key. Args: tool: The key of the tool prompt to retrieve. Returns: The tool prompt

Update a record by upserting with the same point ID.

Update workspace dependency versions in pyproject.toml. Args: file_path: Path to pyproject.toml file. new_version: New version st

Show the installed version of crewai.

Add message to state conversation history. Args: text: Message content. role: Message role (default: assistant).

Create a file only if it doesn't already exist.

Build a realistic multi-turn conversation for summarization tests.

Convert a config dict from crewai-oauth into an MCPServerConfig.

Calls the LLM with function calling to get a plan. Args: prompt: The prompt to send to the LLM. plan_type: The type o

Convert contents to dict format.

Helper to write JSON data to a temporary file and return its path.

A minimal crew whose agent goal references each ``{name}`` placeholder.

Delete a secure file (no-op if absent).

Execute a single table write with retry on commit conflicts. Caller must already hold ``store_lock(self._lock_name)``.

Build a rankable catalog entry. ``sort`` is a comparable tuple ``(created, date_int, version_tuple)`` so a real vendor timestamp wins, then a

Estimate token count using a conservative cross-provider heuristic. Args: text: The text to estimate tokens for. Returns: Es

Fetch all template repos from the GitHub org.

Derives the custom_llm_provider from the model string. - For example, if the model is "openrouter/deepseek/deepseek-chat", returns "o

Get or create the encryption key.

Handle the events for the LLM call. Args: response (str): The response from the LLM call. call_type (str): The type o

GET ``url`` and return parsed JSON, with a short timeout and TLS verify.

Derive a readable label from a raw model id. Best-effort only — vendor display names and the curated label map take precedence. Drops embedde

Inject the current date into the task description if inject_date is enabled.

Replace CrewRunApp/EventListener/summary so _run_declarative_flow_tui is driven by a controllable fake app.

Check if the error message indicates a context length limit error. Args: error_message: The error message to check. Retu

Build a simple chain: e0 → e1 → e2 → ... with previous_event_id.

Create a TraceBatchManager with a pre-set trace_batch_id.

Mark a trace batch as failed, routing to the correct endpoint.

Normalize Ollama base URL to ensure it ends with /v1. Ollama uses OLLAMA_HOST which may not include the /v1 suffix, but the OpenAI-compatible

Return a Snowflake Cortex REST OpenAI-compatible base URL.

Convert raw input to appropriate source type.

Format a class or instance as the canonical ``module:qualname`` ref.

Parse LLM output as AgentResponse or return raw agent response.

Prepare generation config for Google Gemini API. Args: system_instruction: System instruction for the model tools: To

Prepare common setup for kickoff execution. This method handles all the common preparation logic shared between kickoff() and kickoff

Params with an explicit `reasoning_effort="none"`, or None if already set. Removing the key is not enough: absence means "use the server defa

Resolve an HTTPS MCP server URL into tools.

Resolve an ``MCPServerConfig`` into tools. Returns ``(tools, clients)`` where *clients* is always empty for native tools (clients are

Build a ``_ScriptedFlow``, attach ``script``, kickoff. Returns the flow.

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

Save task output to a file. Note: For cross-platform file writing, especially on Windows, consider using FileWriterTool

Scan rows optionally filtered by scope prefix. Uses a full table scan (no vector query) so the limit is applied after the scope filte

Display a standard error message when no UUID or project name is available.

Unregister a stream handler from the event bus. Args: handler: The handler function to unregister.

Validate parameters before making a call. Currently this only checks if a response_format is provided and whether the model supports

Validate file size against maximum. Args: file_type: Type label for error messages (e.g., "Image", "PDF"). filename: Name of the

Create a new collection in Qdrant asynchronously. Keyword Args: collection_name: Name of the collection to create. Must be unique

Download a template and copy it into the current working directory. Args: name: Template name (with or without the template_ pref

Add usage metrics from another UsageMetrics object. Args: usage_metrics: The usage metrics to add.

Delete a collection and all its data asynchronously. Keyword Args: collection_name: Name of the collection to delete. Ra

Execute a task with the agent asynchronously. Args: task: Task to execute. context: Context to execute the task in.

Asynchronously invoke the tool. Args: input: The input arguments config: Optional configuration **kwargs:

Async read the file content as bytes. Raises: TypeError: If the underlying source doesn't support async read.

Run the flow asynchronously and stream scoped public frames.

Call Anthropic messages API. Args: messages: Input messages for the chat completion tools: List of tool/function defi

Check if max iterations reached before proceeding with reasoning.

Write a checkpoint. Args: location: Storage destination. For JsonProvider this is a directory path; for SqlitePro

Write a JSON checkpoint file. Args: data: The serialized JSON string to persist. location: Base directory where check

Classify an exception as transient or permanent upload error. Analyzes the exception type name and status code to determine if the error is l

Sync wrapper for aclear.

Clear files for a crew execution. Args: execution_id: Unique identifier for the crew execution.

Clear files for a task execution. Args: task_id: Unique identifier for the task.

Return a configured CrewAI definition path for a project type. ``[tool.crewai].type`` must match ``project_type`` and ``definition`` must be

Convert a path to a Path object.

Create a converter instance based on the agent or provided class. Args: agent: The agent instance. converter_cls: The converter c

Create ``branch`` from current HEAD, resetting any stale copy. If the branch exists locally or on origin, prompts the user to choose between

Disconnect from MCP server and cleanup resources.

Generate embedding for a single text. Args: text: Text to embed Returns: List of floats representin

Ensure all schema objects in anyOf/oneOf have a 'type' key. OpenAI strict mode requires every schema to have a 'type' key. Empty schemas {} i

Execute a tool and check if the result should be treated as a final answer. This function integrates tool hooks for before and after tool executi

Extract ``(finish_reason, response_id)`` from a choices-shaped response. Handles both object-style (``response.id``, ``response.choices[0].finish

Extract the checkpoint ID from a location string. Args: location: The identifier returned by a previous ``checkpoint`` call.