Train the crew by running a command in the UV environment. Args: n_iterations (int): The number of iterations to train the crew.

Context manager to set the triggering event ID for causal chain tracking. All events emitted within this context will have their triggered_by_eve

Update an existing task output in storage. Args: task_index: The index of the task to update. log: Dictionary contain

Validate a file against provider constraints. Args: file: The file to validate. Returns: List of validation

Validate that a directory path is safe to read. Same as :func:`validate_file_path` but also checks that the path is an existing directory.

Validate a file against provider constraints. Dispatches to the appropriate validator based on file type. Args: file: The file to va

Validate an image file against constraints. Args: file: The image file to validate. constraints: Image constraints to validate ag

Asynchronously call provided async handlers. Args: source: The object that emitted the event event: The event instanc

Executes tasks using native async and returns the final output. Args: tasks: List of tasks to execute start_index: In

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

Build an EdgeConfig for the given vector dimensionality.

Build an S3 URI from a key. Args: key: The S3 object key. Returns: S3 URI string.

Atomically check max usage and increment the counter. Returns: None if usage was claimed successfully, or an error message

Convert tools to a format that can be used for interference. Args: tools: List of tools to convert. Returns:

Copy metadata from original function to wrapper. Args: wrapper: The wrapper object to copy metadata to original: The original fun

Create a copy of the current state. Returns: A copy of the current state

Create a hook decorator with filtering support. This factory function eliminates code duplication across the four hook decorators. Args:

Helper to create mock plan response.

Creates a summary of all tasks. Returns: A string summarizing all tasks with their details.

Delegate to A2A agent with multi-turn conversation support. Args: self: The agent instance agent_response: The AgentResponse indi

Build the deployment show URL, resolving UUID-only responses if needed.

Display deployment information. Args: json_response (Dict[str, Any]): The deployment information to display.

Create a BTREE scalar index on the ``scope`` column if not present. A scalar index lets LanceDB skip a full table scan when filtering by

Execute the first tool from the tool_uses list and return its result. This is used when available_functions is provided, to directly execute

Execute a project script through uv. Args: script_name: The project script to run. entity_type: The user-facing entity being run.

Extract token usage and response metadata from Azure response.

Extract and parse all built-in tool outputs from Responses API. Parses web_search, file_search, code_interpreter, computer_use, and r

Extract raw finish_reason (``stopReason``) from a Bedrock Converse response dict. Defensive — returns (None, None) on any failure. Be

Extract reasoning items with encrypted content from response. Used for ZDR (Zero Data Retention) compliance to capture encrypted reas

Extract finish_reason and response_id from an OpenAI Responses API ``Response`` object. The Responses API exposes ``status`` rather th

Send batch finalization to backend Args: events_count: Number of events that were successfully sent

Format feedback as a message.

Get or create the async OpenAI client.

Return the path to the version cache file, creating the dir if needed.

Get or create the S3 client.

Get or create the Anthropic client.

Get client parameters for compatibility with base class. Note: This method is kept for compatibility but the Google Gen AI SDK uses a

Extract collection creation parameters from kwargs.

Retrieve a memory prompt from the i18n translations. Args: key: The prompt key under the "memory" section. Returns: The prom

Get unique provider names from cache entries. Args: cache: The upload cache. Returns: Set of provider names.

Extract user context for tracing.

Get video duration in seconds using av if available. Args: content: Raw video bytes. content_type: Optional MIME type for format

Handle a tool call from the LLM. Args: tool_calls: List of tool calls from the LLM available_functions: Dict of avail

Import docling submodules lazily and cache the result. Raises: ImportError: If the docling package is not installed.

Increment the usage count.

Initialize trace batch - auto-enable ephemeral for first-time users. Args: user_context: User context information. ex

Inject merged metadata into call details.

Interpolates the inputs in the tasks and agents.

Type guard to check if the embedding function is async. Args: func: The embedding function to check. Returns: True if the fu

Check if a version string represents a pre-release.

Check if an object is a Pydantic model class. This distinguishes between Pydantic model classes that support structured outputs (have model_j

Return True for regular files, excluding symlinks to files.

Create a TraceBatchManager with a pre-set trace_batch_id.

Build a MethodExecutionStartedEvent with explicit ids/sequence.

Parse and validate the input arguments against the schema. Args: raw_args: The raw arguments to parse, either as a string or dict

Reconstruct a MemoryRecord from a Qdrant payload.

Poll the token endpoint until authentication completes or times out.

Capture execution context and sync checkpoint fields on each entity. Args: root: List of entities to prepare for serialization.

Preprocess structured data to handle common LLM output format issues. Some models (especially Claude on Bedrock) may return array fields as m

Resolve user input to a full repo name, or None if not found.

Retry an operation with exponential backoff. Args: operation: Async operation to retry. timeout: Operation timeout in

Run the crew with the trigger payload using the run_with_trigger method.

Set task identity and fingerprint data on an event.

Set up messages for the agent execution.

Whether this kickoff should defer final flow trace finalization.

Whether to run PlannerObserver LLM calls after each step. Explicit ``observe_steps=False`` disables observation at any effort level.

Submit a save operation to the background thread pool. The future is tracked so that ``drain_writes()`` can wait for it. If the pool

Check if the model supports native structured outputs. Native structured outputs are only available for Claude 4.5 models (Sonnet 4.5, Opus 4

Build an in-memory tar archive via `build(tf)` and return it for reading.

Parse streamed observation JSON and update the exact step it names.

Remove key tracking for a provider.

Convert a UUID string to a stable Qdrant point ID. Falls back to hashing for non-UUID strings.

Validate keyword arguments against args_schema if present. Args: kwargs: The keyword arguments to validate. Returns:

Call the LLM with the given messages. Args: messages: Input messages for the LLM. Can be a string or list of

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

Get all cached uploads for a provider. Args: provider: The provider name. Returns: List of cached uploads fo