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), 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.

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.

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

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

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

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)

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

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

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

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.

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.

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

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.

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