Get OpenAI client parameters.

Stable, privacy-preserving machine fingerprint (cross-platform).

Invoke step callback if configured. Args: formatted_answer: Current agent response.

Return True if the cache is less than 24 hours old.

Make a JSON-RPC 2.0 MCP request to Agent Handler.

Whether a 400 is OpenAI refusing `reasoning_effort` alongside tools. GPT-5.6 applies a server-side `reasoning_effort` default and then reject

Re-subscribe the global listener to the event bus. The repo-wide ``cleanup_event_handlers`` fixture clears every handler after each test, so

Import a module and walk attribute lookups to resolve a dotted path. Handles multi-level qualified names like ``"module.ClassName.method"`` b

Translate a chat-format message into Responses ``input`` items. Tool calling is expressed differently by the two APIs. Chat Completions

Track token usage internally in the LLM instance. Args: usage_data: Token usage data from the API response

Validate the search query to ensure it's safe to execute. Only SELECT and SHOW statements are allowed for security reasons. Args:

Cancel streaming and clean up resources.

Add content to the knowledge base.

Start an execution context unless one is already active. The outermost crew or flow receives a new uuid by default. Nested executions inherit

Split a text file into chunks of maximum character count. Yields chunks one at a time to minimize memory usage. Args: file: The text

Creates a deep copy of the Crew instance. Returns: Crew: A new instance with copied components

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

Detect MIME type from file content. Uses python-magic if available for accurate content-based detection, falls back to mimetypes module using

Build the exception matching an HTTP status. Args: status_code: HTTP status the server responded with. detail: Optional underlyin

Force additionalProperties=false on all object-type dicts recursively. OpenAI strict mode requires all objects to have additionalProperties=false

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

Generate a UUID-based filename with extension from content type. Args: content_type: MIME type to derive extension from. Returns:

Get the actions available for the selected applications.

Get merged crew and task files. Task files override crew files with the same name. Args: crew_id: Unique identifier for the crew exe

Get the current crew context from OpenTelemetry baggage. Returns: CrewContext instance containing crew context information, or None if no

Return the generated-project dependency for CrewAI with tools.

Get an existing collection or create it if it doesn't exist. Keyword Args: collection_name: Name of the collection to get or crea

Extract tool call streaming events from mock emit calls.

Get the ID of the event that triggered the current execution. Returns: The event_id of the triggering event, or None if not in a triggere

Check if this cached upload has expired.

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

Normalize a scope path by removing double slashes and ensuring proper format. Args: path: The raw scope path (e.g. '/crew/MyCrewName//age

Parse '@org/skill-name' into (org, name), ignoring any version pin. Retained for backwards compatibility. Use :func:`parse_skill_ref` to read

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

Request human input during LLM hook execution. This method pauses live console updates, displays a prompt to the user, waits for thei

Recursively resolve all local $refs in the given JSON Schema using $defs as the source. This is needed because Pydantic generates $ref-based sche

Set the platform integration token in the current context. Args: integration_token: The integration token to set.

Strip JSONC comments and trailing commas while preserving string values.

Remove format annotations that OpenAI strict mode doesn't support. OpenAI only supports: date-time, date, time, duration. Other formats like

Check if the model supports function calling. Note: This method is only used by the litellm fallback path. Native providers override

Check if the model supports stop words. Note: This method is only used by the litellm fallback path. Native providers override this m

Collect the failures of one execution, isolated from concurrent ones. An agent may be shared by tasks running concurrently, so accumulating on

Get all available agent tools

Support instance methods by implementing the descriptor protocol. Args: obj: The instance that the method is accessed through.

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

Create a skill directory containing a minimal SKILL.md.

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

Initialize backend batch and send collected events.

Install *client* the way a hosted runtime does.

True when ``ALLOW_UNSAFE_PATHS`` is set and ``FORCE_SAFE_PATHS`` is not.

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.

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

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 a collapse/learn LLM the same way agents resolve theirs. Explicit decorator values win. ``None`` follows ``create_llm``: ``MODEL`` /

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.