Get the filesystem path if file source is FilePath. Args: file: The file input to check. Returns: Path if source is FilePath

Get inference configuration following AWS Converse API specification.

Generate a search query for the knowledge base based on the task description.

Get max replans from planning config or default to 3.

Look up a dotted attribute path inside ``pyproject_path``. The file must declare ``crewai`` in ``[project].dependencies`` for the lookup to s

Get the reasoning effort level from the agent's planning config. Returns: The reasoning effort level: "low", "medium", or "high".

Get A2AServerConfig from an agent's a2a configuration. Args: agent: The Agent instance to check. Returns: A2AServerConfig if

Build a getattr side_effect that resolves the patched tool name to ``tool_cls`` while delegating every other lookup (e.g. the ``is_deprecated_

True when either shard already holds persisted records.

Return True when the project has a Poetry lockfile.

Return True when the project has a uv lockfile.

Heuristically reject embedding/audio/image/etc. models by their id.

Detect if we're running in a test environment.

Return True if *instance* validates against *schema*.

Return a cross-process lock context manager, or nullcontext if no lock name.

Create a TraceBatchManager with a pre-set trace_batch_id (simulating first-time user).

Create a FirstTimeTraceHandler wired to a TraceBatchManager.

Create a cache key from file hash and provider.

Build a message list that will produce exactly *n* chunks. Each message has 400 chars (~100 tokens). With max_tokens=100 returned by

Observe a completed step via LLM or a lightweight heuristic.

Open the deployment show page in the user's browser when possible.

Open an existing shard or create a new one at *path*.

Poll a GitHub PR until it is merged. Exit if closed without merging. Args: branch_name: Branch name to look up the PR. label: Hum

Return the start-time state for a completion/failure event's task. Tasks can run async/overlapping, so the event's task identity is m

Prepare Git for deploy while preserving remote deploy when possible.

Register a handler for the given event type. Args: event_type: The event class to listen for handler: The handler fun

Record that this model must use the Responses API.

Resolve kickoff inputs for a declarative crew. Mirrors the declarative-flow experience (``_resolve_flow_inputs``): layers ``--inputs`` over t

Resolve crew-level skill paths once so agents don't repeat the work.

Resolve a potentially async result to its value.

Execute the Agent Handler tool with the given arguments.

Send buffered events to backend with graceful failure handling

Set fingerprint data on an event from an agent object.

Update a flow method step's status. Caller must hold ``self._lock``.

Set the final result after streaming completes. Args: result: The final CrewOutput.

Set the read and write streams. Args: read: Read stream. write: Write stream.

Setup and invoke after_llm_call hooks for the executor context. Args: executor_context: The executor context to setup the hooks for.

True when the active trace belongs to a deferred flow session.

Reject like GPT-5.6 until an explicit reasoning_effort="none" arrives. The reasoning planner calls the LLM with its own `available_functions`

Return a stable lock name for the user data file.

Validate content type against supported formats. Args: file_type: Type label for error messages (e.g., "Image", "Audio"). filenam

Write a project-local ./skills/<name>/SKILL.md under *tmp_path*.

Async call to Anthropic messages API. Args: messages: Input messages for the chat completion tools: List of tool/func

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

Add an edge from this node to another. Args: edge_type: The relationship type. target_id: The event_id of the target

Async delete an uploaded file. Default implementation runs sync delete in executor. Override in subclasses for native async support.

Get a cached upload by file hash. Args: file_hash: Hash of the file content. provider: The provider name. Re

Retrieve files for a crew execution asynchronously. Args: execution_id: Unique identifier for the crew execution. Returns: D

Record an agent result, optionally making it visible to the user.

Append a message to ``state.messages`` or the flow fallback buffer.

Write an ExecutionContext back into the ContextVars.

Save documents to the knowledge base asynchronously. Args: documents: List of document strings to save.

Search for documents in the knowledge base asynchronously. Args: query: List of query strings. limit: Maximum number

Cache an uploaded file by hash. Args: file_hash: Hash of the file content. content_type: MIME type of the file.