Extract output from code interpreter response stream. Args: response: Response from code interpreter execution Returns: Extr

Restore a Crew from a checkpoint, ready to resume via kickoff(). Args: config: Checkpoint configuration with ``restore_from`` set

Get the current parent event ID from the stack.

Initialize a new trace batch (thread-safe)

Return ``(yanked, reason)`` for the currently installed version.

Check if tracing is enabled in current execution context. Returns: True if tracing is enabled in context, False otherwise. Return

Return ``message`` with the cache-breakpoint flag set. Returns a new dict so callers can safely pass literal dicts.

Mark a todo as completed by step number.

Push an event ID and type onto the scope stack.

Register a global after_llm_call hook. Global hooks are added to all executors automatically. This is a convenience function for registering

Register a global before_llm_call hook. Global hooks are added to all executors automatically. This is a convenience function for registering

Save the data to the specified file using pickle. Args: data: The data to be saved to the file.

Convert a dotted path string to the callable it references. If *value* is already callable it is returned as-is, with a warning if it cannot

Generate a standard prompt for task execution. Returns: A dictionary containing the constructed prompt(s).

Validate an audio file against constraints. Args: file: The audio file to validate. constraints: Audio constraints to validate ag

Common payload refinement for all tools.

Helper to create a skill directory with SKILL.md.

Emit one fake ``LLMCallCompletedEvent`` with ``current_flow_id`` pinned to ``flow_id``. Runs in a freshly-copied context so the value the bus

Fetch action schemas from the platform API.

Format messages for OpenAI API.

Format messages for Converse API following AWS documentation. Note: Returns dict[str, Any] instead of LLMMessage because Bedrock uses

Get or create the Gemini client.

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.

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

Split messages into chunks at message boundaries. Excludes system messages from chunks. Each chunk stays under max_tokens based on estimated

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.

Promote a skill to INSTRUCTIONS disclosure level. Idempotent: returns the skill unchanged if already at or above INSTRUCTIONS. Args:

Add content to the knowledge base.

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

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

Build an expression with the standard Flow runtime context.

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

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.

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). Args: ref: A registry reference, e.g. '@acme/my-skill'. Returns: A (org, name) tup

Recall relevant memories. Delegates to this flow's memory. Args: query: Natural language query. **kwargs: Passed to m

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.

Unpack an archive into the cache and write metadata. Uses tarfile with filter='data' for path-traversal protection. Args:

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

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

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.

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

Get OpenAI client parameters.

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

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.