refactor: extract a2a into standalone crewai-a2a package

Move crewai.a2a into lib/crewai-a2a as its own workspace package, importable as crewai_a2a. The crewai[a2a] extra now pulls in crewai-a2a, which owns a2a-sdk, httpx-auth, httpx-sse, and aiocache.

crewai.a2a stays importable. Its __init__ is a compat shim that installs a meta-path finder routing crewai.a2a.* to crewai_a2a.*, so existing user code keeps working untouched.

a2a tests and cassettes moved alongside the package under lib/crewai-a2a/tests/. Added that path to the mypy and ruff per-file-ignores lists to match the other test dirs.

.pre-commit-config.yaml

@@ -19,11 +19,19 @@ repos:
         language: system
         pass_filenames: true
         types: [python]
-        exclude: ^(lib/crewai/src/crewai/cli/templates/|lib/crewai/tests/|lib/crewai-tools/tests/|lib/crewai-files/tests/)
+        exclude: ^(lib/crewai/src/crewai/cli/templates/|lib/crewai/tests/|lib/crewai-tools/tests/|lib/crewai-files/tests/|lib/crewai-a2a/tests/)
   - repo: https://github.com/astral-sh/uv-pre-commit
     rev: 0.11.3
     hooks:
       - id: uv-lock
+  - repo: local
+    hooks:
+      - id: pip-audit
+        name: pip-audit
+        entry: bash -c 'source .venv/bin/activate && uv run pip-audit --skip-editable --ignore-vuln CVE-2025-69872 --ignore-vuln CVE-2026-25645 --ignore-vuln CVE-2026-27448 --ignore-vuln CVE-2026-27459 --ignore-vuln PYSEC-2023-235' --
+        language: system
+        pass_filenames: false
+        stages: [pre-push, manual]
   - repo: https://github.com/commitizen-tools/commitizen
     rev: v4.10.1
     hooks:

docs/ar/changelog.mdx

@@ -4,6 +4,36 @@ description: "تحديثات المنتج والتحسينات وإصلاحات
 icon: "clock"
 mode: "wide"
 ---
+<Update label="13 أبريل 2026">
+  ## v1.14.2a3
+
+  [عرض الإصدار على GitHub](https://github.com/crewAIInc/crewAI/releases/tag/1.14.2a3)
+
+  ## ما الذي تغير
+
+  ### الميزات
+  - إضافة واجهة سطر الأوامر للتحقق من النشر
+  - تحسين سهولة استخدام تهيئة LLM
+
+  ### إصلاحات الأخطاء
+  - تجاوز pypdf و uv إلى إصدارات مصححة لـ CVE-2026-40260 و GHSA-pjjw-68hj-v9mw
+  - ترقية requests إلى >=2.33.0 لمعالجة ثغرة ملف مؤقت CVE
+  - الحفاظ على معلمات استدعاء أداة Bedrock من خلال إزالة القيمة الافتراضية الصحيحة
+  - تنظيف مخططات الأدوات لوضع صارم
+  - إصلاح اختبار تسلسل تضمين MemoryRecord
+
+  ### الوثائق
+  - تنظيف لغة A2A الخاصة بالمؤسسات
+  - إضافة وثائق ميزات A2A الخاصة بالمؤسسات
+  - تحديث وثائق A2A الخاصة بالمصادر المفتوحة
+  - تحديث سجل التغييرات والإصدار لـ v1.14.2a2
+
+  ## المساهمون
+
+  @Yanhu007, @greysonlalonde
+
+</Update>
+
 <Update label="10 أبريل 2026">
   ## v1.14.2a2
 

docs/docs.json

@@ -392,7 +392,8 @@
                       "en/enterprise/features/marketplace",
                       "en/enterprise/features/agent-repositories",
                       "en/enterprise/features/tools-and-integrations",
-                      "en/enterprise/features/pii-trace-redactions"
+                      "en/enterprise/features/pii-trace-redactions",
+                      "en/enterprise/features/a2a"
                     ]
                   },
                   {
@@ -865,7 +866,8 @@
                       "en/enterprise/features/marketplace",
                       "en/enterprise/features/agent-repositories",
                       "en/enterprise/features/tools-and-integrations",
-                      "en/enterprise/features/pii-trace-redactions"
+                      "en/enterprise/features/pii-trace-redactions",
+                      "en/enterprise/features/a2a"
                     ]
                   },
                   {
@@ -1338,7 +1340,8 @@
                       "en/enterprise/features/marketplace",
                       "en/enterprise/features/agent-repositories",
                       "en/enterprise/features/tools-and-integrations",
-                      "en/enterprise/features/pii-trace-redactions"
+                      "en/enterprise/features/pii-trace-redactions",
+                      "en/enterprise/features/a2a"
                     ]
                   },
                   {
@@ -1811,7 +1814,8 @@
                       "en/enterprise/features/marketplace",
                       "en/enterprise/features/agent-repositories",
                       "en/enterprise/features/tools-and-integrations",
-                      "en/enterprise/features/pii-trace-redactions"
+                      "en/enterprise/features/pii-trace-redactions",
+                      "en/enterprise/features/a2a"
                     ]
                   },
                   {
@@ -2283,7 +2287,8 @@
                       "en/enterprise/features/marketplace",
                       "en/enterprise/features/agent-repositories",
                       "en/enterprise/features/tools-and-integrations",
-                      "en/enterprise/features/pii-trace-redactions"
+                      "en/enterprise/features/pii-trace-redactions",
+                      "en/enterprise/features/a2a"
                     ]
                   },
                   {
@@ -2754,7 +2759,8 @@
                       "en/enterprise/features/marketplace",
                       "en/enterprise/features/agent-repositories",
                       "en/enterprise/features/tools-and-integrations",
-                      "en/enterprise/features/pii-trace-redactions"
+                      "en/enterprise/features/pii-trace-redactions",
+                      "en/enterprise/features/a2a"
                     ]
                   },
                   {
@@ -3225,7 +3231,8 @@
                       "en/enterprise/features/marketplace",
                       "en/enterprise/features/agent-repositories",
                       "en/enterprise/features/tools-and-integrations",
-                      "en/enterprise/features/pii-trace-redactions"
+                      "en/enterprise/features/pii-trace-redactions",
+                      "en/enterprise/features/a2a"
                     ]
                   },
                   {
@@ -3698,7 +3705,8 @@
                       "en/enterprise/features/marketplace",
                       "en/enterprise/features/agent-repositories",
                       "en/enterprise/features/tools-and-integrations",
-                      "en/enterprise/features/pii-trace-redactions"
+                      "en/enterprise/features/pii-trace-redactions",
+                      "en/enterprise/features/a2a"
                     ]
                   },
                   {
@@ -4169,7 +4177,8 @@
                       "en/enterprise/features/marketplace",
                       "en/enterprise/features/agent-repositories",
                       "en/enterprise/features/tools-and-integrations",
-                      "en/enterprise/features/pii-trace-redactions"
+                      "en/enterprise/features/pii-trace-redactions",
+                      "en/enterprise/features/a2a"
                     ]
                   },
                   {
@@ -4643,7 +4652,8 @@
                       "en/enterprise/features/marketplace",
                       "en/enterprise/features/agent-repositories",
                       "en/enterprise/features/tools-and-integrations",
-                      "en/enterprise/features/pii-trace-redactions"
+                      "en/enterprise/features/pii-trace-redactions",
+                      "en/enterprise/features/a2a"
                     ]
                   },
                   {

docs/en/changelog.mdx

@@ -4,6 +4,36 @@ description: "Product updates, improvements, and bug fixes for CrewAI"
 icon: "clock"
 mode: "wide"
 ---
+<Update label="Apr 13, 2026">
+  ## v1.14.2a3
+
+  [View release on GitHub](https://github.com/crewAIInc/crewAI/releases/tag/1.14.2a3)
+
+  ## What's Changed
+
+  ### Features
+  - Add deploy validation CLI
+  - Improve LLM initialization ergonomics
+
+  ### Bug Fixes
+  - Override pypdf and uv to patched versions for CVE-2026-40260 and GHSA-pjjw-68hj-v9mw
+  - Upgrade requests to >=2.33.0 for CVE temp file vulnerability
+  - Preserve Bedrock tool call arguments by removing truthy default
+  - Sanitize tool schemas for strict mode
+  - Deflake MemoryRecord embedding serialization test
+
+  ### Documentation
+  - Clean up enterprise A2A language
+  - Add enterprise A2A feature documentation
+  - Update OSS A2A documentation
+  - Update changelog and version for v1.14.2a2
+
+  ## Contributors
+
+  @Yanhu007, @greysonlalonde
+
+</Update>
+
 <Update label="Apr 10, 2026">
   ## v1.14.2a2
 

docs/en/enterprise/features/a2a.mdx

@@ -0,0 +1,227 @@
+---
+title: A2A on AMP
+description: Production-grade Agent-to-Agent communication with distributed state and multi-scheme authentication
+icon: "network-wired"
+mode: "wide"
+---
+
+<Warning>
+A2A server agents on AMP are in early release. APIs may change in future versions.
+</Warning>
+
+## Overview
+
+CrewAI AMP extends the open-source [A2A protocol implementation](/en/learn/a2a-agent-delegation) with production infrastructure for deploying distributed agents at scale. AMP supports A2A protocol versions 0.2 and 0.3. When you deploy a crew or agent with A2A server configuration to AMP, the platform automatically provisions distributed state management, authentication, multi-transport endpoints, and lifecycle management.
+
+<Note>
+  For A2A protocol fundamentals, client/server configuration, and authentication schemes, see the [A2A Agent Delegation](/en/learn/a2a-agent-delegation) documentation. This page covers what AMP adds on top of the open-source implementation.
+</Note>
+
+### Usage
+
+Add `A2AServerConfig` to any agent in your crew and deploy to AMP. The platform detects agents with server configuration and automatically registers A2A endpoints, generates agent cards, and provisions the infrastructure described below.
+
+```python
+from crewai import Agent, Crew, Task
+from crewai.a2a import A2AServerConfig
+from crewai.a2a.auth import EnterpriseTokenAuth
+
+agent = Agent(
+    role="Data Analyst",
+    goal="Analyze datasets and provide insights",
+    backstory="Expert data scientist with statistical analysis skills",
+    llm="gpt-4o",
+    a2a=A2AServerConfig(
+        auth=EnterpriseTokenAuth()
+    )
+)
+
+task = Task(
+    description="Analyze the provided dataset",
+    expected_output="Statistical summary with key insights",
+    agent=agent
+)
+
+crew = Crew(agents=[agent], tasks=[task])
+```
+
+After [deploying to AMP](/en/enterprise/guides/deploy-to-amp), the platform registers two levels of A2A endpoints:
+
+- **Crew-level**: an aggregate agent card at `/.well-known/agent-card.json` where each agent with `A2AServerConfig` is listed as a skill, with a JSON-RPC endpoint at `/a2a`
+- **Per-agent**: isolated agent cards and JSON-RPC endpoints mounted at `/a2a/agents/{role}/`, each with its own tenancy
+
+Clients can interact with the crew as a whole or target a specific agent directly. To route a request to a specific agent through the crew-level endpoint, include `"target_agent"` in the message metadata with the agent's slugified role name (e.g., `"data-analyst"` for an agent with role `"Data Analyst"`). If no `target_agent` is provided, the request is handled by the first agent in the crew.
+
+See [A2A Agent Delegation](/en/learn/a2a-agent-delegation#server-configuration-options) for the full list of `A2AServerConfig` options.
+
+<Warning>
+  Per the A2A protocol, agent cards are publicly accessible to enable discovery. This includes both the crew-level card at `/.well-known/agent-card.json` and per-agent cards at `/a2a/agents/{role}/.well-known/agent-card.json`. Do not include sensitive information in agent names, descriptions, or skill definitions.
+</Warning>
+
+### File Inputs and Structured Output
+
+A2A on AMP supports passing files and requesting structured output in both directions. Clients can send files as `FilePart`s and request structured responses by embedding a JSON schema in the message. Server agents receive files as `input_files` on the task, and return structured data as `DataPart`s when a schema is provided. See [File Inputs and Structured Output](/en/learn/a2a-agent-delegation#file-inputs-and-structured-output) for details.
+
+### What AMP Adds
+
+<CardGroup cols={2}>
+  <Card title="Distributed State" icon="database">
+    Persistent task, context, and result storage
+  </Card>
+  <Card title="Enterprise Authentication" icon="shield-halved">
+    OIDC, OAuth2, mTLS, and Enterprise token validation beyond simple bearer tokens
+  </Card>
+  <Card title="gRPC Transport" icon="bolt">
+    Full gRPC server with TLS and authentication
+  </Card>
+  <Card title="Context Lifecycle" icon="clock-rotate-left">
+    Automatic idle detection, expiration, and cleanup of long-running conversations
+  </Card>
+  <Card title="Signed Webhooks" icon="signature">
+    HMAC-SHA256 signed push notifications with replay protection
+  </Card>
+  <Card title="Multi-Transport" icon="arrows-split-up-and-left">
+    REST, JSON-RPC, and gRPC endpoints served simultaneously from a single deployment
+  </Card>
+</CardGroup>
+
+---
+
+## Distributed State Management
+
+In the open-source implementation, task and context state lives in memory on a single process. AMP replaces this with persistent, distributed stores.
+
+### Storage Layers
+
+| Store | Purpose |
+|---|---|
+| **Task Store** | Persists A2A task state and metadata |
+| **Context Store** | Tracks conversation context, creation time, last activity, and associated tasks |
+| **Result Store** | Caches task results for retrieval |
+| **Push Config Store** | Manages webhook subscriptions per task |
+
+Multiple A2A deployments are automatically isolated from each other, preventing data collisions when sharing infrastructure.
+
+---
+
+## Enterprise Authentication
+
+AMP supports six authentication schemes for incoming A2A requests, configurable per deployment. Authentication works across both HTTP and gRPC transports.
+
+| Scheme | Description | Use Case |
+|---|---|---|
+| **SimpleTokenAuth** | Static bearer token from `AUTH_TOKEN` env var | Development, simple deployments |
+| **EnterpriseTokenAuth** | Token verification via CrewAI PlusAPI with integration token claims | AMP-to-AMP agent communication |
+| **OIDCAuth** | OpenID Connect JWT validation with JWKS endpoint caching | Enterprise SSO integration |
+| **OAuth2ServerAuth** | OAuth2 with configurable scopes | Fine-grained access control |
+| **APIKeyServerAuth** | API key validation via header or query parameter | Third-party integrations |
+| **MTLSServerAuth** | Mutual TLS certificate-based authentication | Zero-trust environments |
+
+The configured auth scheme automatically populates the agent card's `securitySchemes` and `security` fields. Clients discover authentication requirements by fetching the agent card before making requests.
+
+---
+
+## Extended Agent Cards
+
+AMP supports role-based skill visibility through extended agent cards. Unauthenticated users see the standard agent card with public skills. Authenticated users receive an extended card with additional capabilities.
+
+This enables patterns like:
+- Public agents that expose basic skills to anyone, with advanced skills available to authenticated clients
+- Internal agents that advertise different capabilities based on the caller's identity
+
+---
+
+## gRPC Transport
+
+If enabled, AMP provides full gRPC support alongside the default JSON-RPC transport.
+
+- **TLS termination** with configurable certificate and key paths
+- **gRPC reflection** for debugging with tools like `grpcurl`
+- **Authentication** using the same schemes available for HTTP
+- **Extension validation** ensuring clients support required protocol extensions
+- **Version negotiation** across A2A protocol versions 0.2 and 0.3
+
+For deployments exposing multiple agents, AMP automatically allocates per-agent gRPC ports and coordinates TLS, startup, and shutdown across all servers.
+
+---
+
+## Context Lifecycle Management
+
+AMP tracks the lifecycle of A2A conversation contexts and automatically manages cleanup.
+
+### Lifecycle States
+
+| State | Condition | Action |
+|---|---|---|
+| **Active** | Context has recent activity | None |
+| **Idle** | No activity for a configured period | Marked idle, event emitted |
+| **Expired** | Context exceeds its maximum lifetime | Marked expired, associated tasks cleaned up, event emitted |
+
+A background cleanup task runs hourly to scan for idle and expired contexts. All state transitions emit CrewAI events that integrate with the platform's observability features.
+
+---
+
+## Signed Push Notifications
+
+When an A2A agent sends push notifications to a client webhook, AMP signs each request with HMAC-SHA256 to ensure integrity and prevent tampering.
+
+### Signature Headers
+
+| Header | Purpose |
+|---|---|
+| `X-A2A-Signature` | HMAC-SHA256 signature in `sha256={hex_digest}` format |
+| `X-A2A-Signature-Timestamp` | Unix timestamp bound to the signature |
+| `X-A2A-Notification-Token` | Optional notification auth token |
+
+### Security Properties
+
+- **Integrity**: payload cannot be modified without invalidating the signature
+- **Replay protection**: signatures are timestamp-bound with a configurable tolerance window
+- **Retry with backoff**: failed deliveries retry with exponential backoff
+
+---
+
+## Distributed Event Streaming
+
+In the open-source implementation, SSE streaming works within a single process. AMP propagates SSE events across instances so that clients receive updates even when the instance holding the streaming connection differs from the instance executing the task.
+
+---
+
+## Multi-Transport Endpoints
+
+AMP serves REST and JSON-RPC by default. gRPC is available as an additional transport if enabled.
+
+| Transport | Path Convention | Description |
+|---|---|---|
+| **REST** | `/v1/message:send`, `/v1/message:stream`, `/v1/tasks` | Google API conventions |
+| **JSON-RPC** | Standard A2A JSON-RPC endpoint | Default A2A protocol transport |
+| **gRPC** | Per-agent port allocation | Optional, high-performance binary protocol |
+
+All active transports share the same authentication, version negotiation, and extension validation. Agent cards are generated from agent and crew metadata — roles, goals, and tools become skills and descriptions — and automatically include interfaces for each active transport. They can also be manually configured via `A2AServerConfig`.
+
+---
+
+## Version and Extension Negotiation
+
+AMP validates A2A protocol versions and extensions at the transport layer.
+
+### Version Negotiation
+
+- Clients send the `A2A-Version` header with their preferred version
+- AMP validates against supported versions (0.2, 0.3) and falls back to 0.3 if unspecified
+- The negotiated version is returned in the response headers
+
+### Extension Validation
+
+- Clients declare supported extensions via the `X-A2A-Extensions` header
+- AMP validates that clients support all extensions the agent requires
+- Requests from clients missing required extensions receive an `UnsupportedExtensionError`
+
+---
+
+## Next Steps
+
+- [A2A Agent Delegation](/en/learn/a2a-agent-delegation) — A2A protocol fundamentals and configuration
+- [A2UI](/en/learn/a2ui) — Interactive UI rendering over A2A
+- [Deploy to AMP](/en/enterprise/guides/deploy-to-amp) — General deployment guide
+- [Webhook Streaming](/en/enterprise/features/webhook-streaming) — Event streaming for deployed automations

docs/en/learn/a2a-agent-delegation.mdx

@@ -7,6 +7,10 @@ mode: "wide"
 
 ## A2A Agent Delegation
 
+<Info>
+  Deploying A2A agents to production? See [A2A on AMP](/en/enterprise/features/a2a) for distributed state, enterprise authentication, gRPC transport, and horizontal scaling.
+</Info>
+
 CrewAI treats [A2A protocol](https://a2a-protocol.org/latest/) as a first-class delegation primitive, enabling agents to delegate tasks, request information, and collaborate with remote agents, as well as act as A2A-compliant server agents.
 In client mode, agents autonomously choose between local execution and remote delegation based on task requirements.
 
@@ -96,24 +100,28 @@ The `A2AClientConfig` class accepts the following parameters:
   Update mechanism for receiving task status. Options: `StreamingConfig`, `PollingConfig`, or `PushNotificationConfig`.
 </ParamField>
 
-<ParamField path="transport_protocol" type="Literal['JSONRPC', 'GRPC', 'HTTP+JSON']" default="JSONRPC">
-  Transport protocol for A2A communication. Options: `JSONRPC` (default), `GRPC`, or `HTTP+JSON`.
-</ParamField>
-
 <ParamField path="accepted_output_modes" type="list[str]" default='["application/json"]'>
   Media types the client can accept in responses.
 </ParamField>
 
-<ParamField path="supported_transports" type="list[str]" default='["JSONRPC"]'>
-  Ordered list of transport protocols the client supports.
-</ParamField>
-
-<ParamField path="use_client_preference" type="bool" default="False">
-  Whether to prioritize client transport preferences over server.
-</ParamField>
-
 <ParamField path="extensions" type="list[str]" default="[]">
-  Extension URIs the client supports.
+  A2A protocol extension URIs the client supports.
+</ParamField>
+
+<ParamField path="client_extensions" type="list[A2AExtension]" default="[]">
+  Client-side processing hooks for tool injection, prompt augmentation, and response modification.
+</ParamField>
+
+<ParamField path="transport" type="ClientTransportConfig" default="ClientTransportConfig()">
+  Transport configuration including preferred transport, supported transports for negotiation, and protocol-specific settings (gRPC message sizes, keepalive, etc.).
+</ParamField>
+
+<ParamField path="transport_protocol" type="Literal['JSONRPC', 'GRPC', 'HTTP+JSON']" default="None">
+  **Deprecated**: Use `transport=ClientTransportConfig(preferred=...)` instead.
+</ParamField>
+
+<ParamField path="supported_transports" type="list[str]" default="None">
+  **Deprecated**: Use `transport=ClientTransportConfig(supported=...)` instead.
 </ParamField>
 
 ## Authentication
@@ -405,11 +413,7 @@ agent = Agent(
   Preferred endpoint URL. If set, overrides the URL passed to `to_agent_card()`.
 </ParamField>
 
-<ParamField path="preferred_transport" type="Literal['JSONRPC', 'GRPC', 'HTTP+JSON']" default="JSONRPC">
-  Transport protocol for the preferred endpoint.
-</ParamField>
-
-<ParamField path="protocol_version" type="str" default="0.3">
+<ParamField path="protocol_version" type="str" default="0.3.0">
   A2A protocol version this agent supports.
 </ParamField>
 
@@ -441,8 +445,36 @@ agent = Agent(
   Whether agent provides extended card to authenticated users.
 </ParamField>
 
-<ParamField path="signatures" type="list[AgentCardSignature]" default="[]">
-  JSON Web Signatures for the AgentCard.
+<ParamField path="extended_skills" type="list[AgentSkill]" default="[]">
+  Additional skills visible only to authenticated users in the extended agent card.
+</ParamField>
+
+<ParamField path="signing_config" type="AgentCardSigningConfig" default="None">
+  Configuration for signing the AgentCard with JWS. Supports RS256, ES256, PS256, and related algorithms.
+</ParamField>
+
+<ParamField path="server_extensions" type="list[ServerExtension]" default="[]">
+  Server-side A2A protocol extensions with `on_request`/`on_response` hooks that modify agent behavior.
+</ParamField>
+
+<ParamField path="push_notifications" type="ServerPushNotificationConfig" default="None">
+  Configuration for outgoing push notifications, including HMAC-SHA256 signing secret.
+</ParamField>
+
+<ParamField path="transport" type="ServerTransportConfig" default="ServerTransportConfig()">
+  Transport configuration including preferred transport, gRPC server settings, JSON-RPC paths, and HTTP+JSON settings.
+</ParamField>
+
+<ParamField path="auth" type="ServerAuthScheme" default="None">
+  Authentication scheme for incoming A2A requests. Defaults to `SimpleTokenAuth` using the `AUTH_TOKEN` environment variable.
+</ParamField>
+
+<ParamField path="preferred_transport" type="Literal['JSONRPC', 'GRPC', 'HTTP+JSON']" default="None">
+  **Deprecated**: Use `transport=ServerTransportConfig(preferred=...)` instead.
+</ParamField>
+
+<ParamField path="signatures" type="list[AgentCardSignature]" default="None">
+  **Deprecated**: Use `signing_config=AgentCardSigningConfig(...)` instead.
 </ParamField>
 
 ### Combined Client and Server
@@ -468,6 +500,14 @@ agent = Agent(
 )
 ```
 
+### File Inputs and Structured Output
+
+A2A supports passing files and requesting structured output in both directions.
+
+**Client side**: When delegating to a remote A2A agent, files from the task's `input_files` are sent as `FilePart`s in the outgoing message. If `response_model` is set on the `A2AClientConfig`, the Pydantic model's JSON schema is embedded in the message metadata, requesting structured output from the remote agent.
+
+**Server side**: Incoming `FilePart`s are extracted and passed to the agent's task as `input_files`. If the client included a JSON schema, the server creates a response model from it and applies it to the task. When the agent returns structured data, the response is sent back as a `DataPart` rather than plain text.
+
 ## Best Practices
 
 <CardGroup cols={2}>

docs/ko/changelog.mdx

@@ -4,6 +4,36 @@ description: "CrewAI의 제품 업데이트, 개선 사항 및 버그 수정"
 icon: "clock"
 mode: "wide"
 ---
+<Update label="2026년 4월 13일">
+  ## v1.14.2a3
+
+  [GitHub 릴리스 보기](https://github.com/crewAIInc/crewAI/releases/tag/1.14.2a3)
+
+  ## 변경 사항
+
+  ### 기능
+  - 배포 검증 CLI 추가
+  - LLM 초기화 사용성 개선
+
+  ### 버그 수정
+  - CVE-2026-40260 및 GHSA-pjjw-68hj-v9mw에 대한 패치된 버전으로 pypdf 및 uv 재정의
+  - CVE 임시 파일 취약점에 대해 requests를 >=2.33.0으로 업그레이드
+  - 진리값 기본값을 제거하여 Bedrock 도구 호출 인수 보존
+  - 엄격 모드를 위한 도구 스키마 정리
+  - MemoryRecord 임베딩 직렬화 테스트의 불안정성 제거
+
+  ### 문서
+  - 기업 A2A 언어 정리
+  - 기업 A2A 기능 문서 추가
+  - OSS A2A 문서 업데이트
+  - v1.14.2a2에 대한 변경 로그 및 버전 업데이트
+
+  ## 기여자
+
+  @Yanhu007, @greysonlalonde
+
+</Update>
+
 <Update label="2026년 4월 10일">
   ## v1.14.2a2
 

docs/pt-BR/changelog.mdx

@@ -4,6 +4,36 @@ description: "Atualizações de produto, melhorias e correções do CrewAI"
 icon: "clock"
 mode: "wide"
 ---
+<Update label="13 abr 2026">
+  ## v1.14.2a3
+
+  [Ver release no GitHub](https://github.com/crewAIInc/crewAI/releases/tag/1.14.2a3)
+
+  ## O que Mudou
+
+  ### Recursos
+  - Adicionar CLI de validação de deploy
+  - Melhorar a ergonomia de inicialização do LLM
+
+  ### Correções de Bugs
+  - Substituir pypdf e uv por versões corrigidas para CVE-2026-40260 e GHSA-pjjw-68hj-v9mw
+  - Atualizar requests para >=2.33.0 devido à vulnerabilidade de arquivo temporário CVE
+  - Preservar os argumentos de chamada da ferramenta Bedrock removendo o padrão truthy
+  - Sanitizar esquemas de ferramentas para modo estrito
+  - Remover flakiness do teste de serialização de embedding MemoryRecord
+
+  ### Documentação
+  - Limpar a linguagem do A2A empresarial
+  - Adicionar documentação de recursos do A2A empresarial
+  - Atualizar documentação do A2A OSS
+  - Atualizar changelog e versão para v1.14.2a2
+
+  ## Contribuidores
+
+  @Yanhu007, @greysonlalonde
+
+</Update>
+
 <Update label="10 abr 2026">
   ## v1.14.2a2
 

lib/crewai-a2a/pyproject.toml

@@ -0,0 +1,22 @@
+[project]
+name = "crewai-a2a"
+dynamic = ["version"]
+description = "Add your description here"
+readme = "README.md"
+authors = [
+    { name = "Greyson LaLonde", email = "greyson@crewai.com" }
+]
+requires-python = ">=3.10, <3.14"
+dependencies = [
+    "a2a-sdk~=0.3.10",
+    "httpx-auth~=0.23.1",
+    "httpx-sse~=0.4.0",
+    "aiocache[redis,memcached]~=0.12.3",
+]
+
+[build-system]
+requires = ["hatchling"]
+build-backend = "hatchling.build"
+
+[tool.hatch.version]
+path = "src/crewai_a2a/__init__.py"

lib/crewai-a2a/src/crewai_a2a/__init__.py

@@ -0,0 +1,13 @@
+"""Agent-to-Agent (A2A) protocol communication module for CrewAI."""
+
+__version__ = "1.14.2a3"
+
+from crewai_a2a.config import A2AClientConfig, A2AConfig, A2AServerConfig
+
+
+__all__ = [
+    "A2AClientConfig",
+    "A2AConfig",
+    "A2AServerConfig",
+    "__version__",
+]

lib/crewai-a2a/src/crewai_a2a/auth/__init__.py

@@ -1,6 +1,6 @@
 """A2A authentication schemas."""
 
-from crewai.a2a.auth.client_schemes import (
+from crewai_a2a.auth.client_schemes import (
     APIKeyAuth,
     AuthScheme,
     BearerTokenAuth,
@@ -11,7 +11,7 @@ from crewai.a2a.auth.client_schemes import (
     OAuth2ClientCredentials,
     TLSConfig,
 )
-from crewai.a2a.auth.server_schemes import (
+from crewai_a2a.auth.server_schemes import (
     AuthenticatedUser,
     EnterpriseTokenAuth,
     OIDCAuth,

lib/crewai-a2a/src/crewai_a2a/auth/schemas.py

@@ -0,0 +1,71 @@
+"""Deprecated: Authentication schemes for A2A protocol agents.
+
+This module is deprecated. Import from crewai_a2a.auth instead:
+- crewai_a2a.auth.ClientAuthScheme (replaces AuthScheme)
+- crewai_a2a.auth.BearerTokenAuth
+- crewai_a2a.auth.HTTPBasicAuth
+- crewai_a2a.auth.HTTPDigestAuth
+- crewai_a2a.auth.APIKeyAuth
+- crewai_a2a.auth.OAuth2ClientCredentials
+- crewai_a2a.auth.OAuth2AuthorizationCode
+"""
+
+from __future__ import annotations
+
+from typing_extensions import deprecated
+
+from crewai_a2a.auth.client_schemes import (
+    APIKeyAuth as _APIKeyAuth,
+    BearerTokenAuth as _BearerTokenAuth,
+    ClientAuthScheme as _ClientAuthScheme,
+    HTTPBasicAuth as _HTTPBasicAuth,
+    HTTPDigestAuth as _HTTPDigestAuth,
+    OAuth2AuthorizationCode as _OAuth2AuthorizationCode,
+    OAuth2ClientCredentials as _OAuth2ClientCredentials,
+)
+
+
+@deprecated("Use ClientAuthScheme from crewai_a2a.auth instead", category=FutureWarning)
+class AuthScheme(_ClientAuthScheme):
+    """Deprecated: Use ClientAuthScheme from crewai_a2a.auth instead."""
+
+
+@deprecated("Import from crewai_a2a.auth instead", category=FutureWarning)
+class BearerTokenAuth(_BearerTokenAuth):
+    """Deprecated: Import from crewai_a2a.auth instead."""
+
+
+@deprecated("Import from crewai_a2a.auth instead", category=FutureWarning)
+class HTTPBasicAuth(_HTTPBasicAuth):
+    """Deprecated: Import from crewai_a2a.auth instead."""
+
+
+@deprecated("Import from crewai_a2a.auth instead", category=FutureWarning)
+class HTTPDigestAuth(_HTTPDigestAuth):
+    """Deprecated: Import from crewai_a2a.auth instead."""
+
+
+@deprecated("Import from crewai_a2a.auth instead", category=FutureWarning)
+class APIKeyAuth(_APIKeyAuth):
+    """Deprecated: Import from crewai_a2a.auth instead."""
+
+
+@deprecated("Import from crewai_a2a.auth instead", category=FutureWarning)
+class OAuth2ClientCredentials(_OAuth2ClientCredentials):
+    """Deprecated: Import from crewai_a2a.auth instead."""
+
+
+@deprecated("Import from crewai_a2a.auth instead", category=FutureWarning)
+class OAuth2AuthorizationCode(_OAuth2AuthorizationCode):
+    """Deprecated: Import from crewai_a2a.auth instead."""
+
+
+__all__ = [
+    "APIKeyAuth",
+    "AuthScheme",
+    "BearerTokenAuth",
+    "HTTPBasicAuth",
+    "HTTPDigestAuth",
+    "OAuth2AuthorizationCode",
+    "OAuth2ClientCredentials",
+]

lib/crewai-a2a/src/crewai_a2a/auth/utils.py

@@ -20,7 +20,7 @@ from a2a.types import (
 )
 from httpx import AsyncClient, Response
 
-from crewai.a2a.auth.client_schemes import (
+from crewai_a2a.auth.client_schemes import (
     APIKeyAuth,
     BearerTokenAuth,
     ClientAuthScheme,

lib/crewai-a2a/src/crewai_a2a/config.py

@@ -20,10 +20,10 @@ from pydantic import (
 )
 from typing_extensions import Self, deprecated
 
-from crewai.a2a.auth.client_schemes import ClientAuthScheme
-from crewai.a2a.auth.server_schemes import ServerAuthScheme
-from crewai.a2a.extensions.base import ValidatedA2AExtension
-from crewai.a2a.types import ProtocolVersion, TransportType, Url
+from crewai_a2a.auth.client_schemes import ClientAuthScheme
+from crewai_a2a.auth.server_schemes import ServerAuthScheme
+from crewai_a2a.extensions.base import ValidatedA2AExtension
+from crewai_a2a.types import ProtocolVersion, TransportType, Url
 
 
 try:
@@ -36,8 +36,8 @@ try:
         SecurityScheme,
     )
 
-    from crewai.a2a.extensions.server import ServerExtension
-    from crewai.a2a.updates import UpdateConfig
+    from crewai_a2a.extensions.server import ServerExtension
+    from crewai_a2a.updates import UpdateConfig
 except ImportError:
     UpdateConfig: Any = Any  # type: ignore[no-redef]
     AgentCapabilities: Any = Any  # type: ignore[no-redef]
@@ -50,7 +50,7 @@ except ImportError:
 
 
 def _get_default_update_config() -> UpdateConfig:
-    from crewai.a2a.updates import StreamingConfig
+    from crewai_a2a.updates import StreamingConfig
 
     return StreamingConfig()
 
@@ -360,8 +360,8 @@ class ClientTransportConfig(BaseModel):
 
 @deprecated(
     """
-    `crewai.a2a.config.A2AConfig` is deprecated and will be removed in v2.0.0,
-    use `crewai.a2a.config.A2AClientConfig` or `crewai.a2a.config.A2AServerConfig` instead.
+    `crewai_a2a.config.A2AConfig` is deprecated and will be removed in v2.0.0,
+    use `crewai_a2a.config.A2AClientConfig` or `crewai_a2a.config.A2AServerConfig` instead.
     """,
     category=FutureWarning,
 )

lib/crewai-a2a/src/crewai_a2a/errors.py

@@ -98,7 +98,6 @@ class A2AErrorCode(IntEnum):
     """The specified artifact was not found."""
 
 
-# Error code to default message mapping
 ERROR_MESSAGES: dict[int, str] = {
     A2AErrorCode.JSON_PARSE_ERROR: "Parse error",
     A2AErrorCode.INVALID_REQUEST: "Invalid Request",

lib/crewai-a2a/src/crewai_a2a/extensions/__init__.py

@@ -13,13 +13,13 @@ via the X-A2A-Extensions header.
 See: https://a2a-protocol.org/latest/topics/extensions/
 """
 
-from crewai.a2a.extensions.base import (
+from crewai_a2a.extensions.base import (
     A2AExtension,
     ConversationState,
     ExtensionRegistry,
     ValidatedA2AExtension,
 )
-from crewai.a2a.extensions.server import (
+from crewai_a2a.extensions.server import (
     ExtensionContext,
     ServerExtension,
     ServerExtensionRegistry,

lib/crewai-a2a/src/crewai_a2a/extensions/a2ui/__init__.py

@@ -1,6 +1,6 @@
 """A2UI (Agent to UI) declarative UI protocol support for CrewAI."""
 
-from crewai.a2a.extensions.a2ui.catalog import (
+from crewai_a2a.extensions.a2ui.catalog import (
     AudioPlayer,
     Button,
     Card,
@@ -20,8 +20,8 @@ from crewai.a2a.extensions.a2ui.catalog import (
     TextField,
     Video,
 )
-from crewai.a2a.extensions.a2ui.client_extension import A2UIClientExtension
-from crewai.a2a.extensions.a2ui.models import (
+from crewai_a2a.extensions.a2ui.client_extension import A2UIClientExtension
+from crewai_a2a.extensions.a2ui.models import (
     A2UIEvent,
     A2UIMessage,
     A2UIResponse,
@@ -31,13 +31,13 @@ from crewai.a2a.extensions.a2ui.models import (
     SurfaceUpdate,
     UserAction,
 )
-from crewai.a2a.extensions.a2ui.server_extension import (
+from crewai_a2a.extensions.a2ui.server_extension import (
     A2UI_STANDARD_CATALOG_ID,
     A2UI_V09_BASIC_CATALOG_ID,
     A2UI_V09_EXTENSION_URI,
     A2UIServerExtension,
 )
-from crewai.a2a.extensions.a2ui.v0_9 import (
+from crewai_a2a.extensions.a2ui.v0_9 import (
     A2UIEventV09,
     A2UIMessageV09,
     ActionEvent,
@@ -68,7 +68,7 @@ from crewai.a2a.extensions.a2ui.v0_9 import (
     UpdateDataModel,
     VideoV09,
 )
-from crewai.a2a.extensions.a2ui.validator import (
+from crewai_a2a.extensions.a2ui.validator import (
     validate_a2ui_event,
     validate_a2ui_event_v09,
     validate_a2ui_message,

lib/crewai-a2a/src/crewai_a2a/extensions/a2ui/client_extension.py

@@ -10,18 +10,18 @@ from pydantic import Field
 from pydantic.dataclasses import dataclass
 from typing_extensions import TypeIs, TypedDict
 
-from crewai.a2a.extensions.a2ui.models import extract_a2ui_json_objects
-from crewai.a2a.extensions.a2ui.prompt import (
+from crewai_a2a.extensions.a2ui.models import extract_a2ui_json_objects
+from crewai_a2a.extensions.a2ui.prompt import (
     build_a2ui_system_prompt,
     build_a2ui_v09_system_prompt,
 )
-from crewai.a2a.extensions.a2ui.server_extension import (
+from crewai_a2a.extensions.a2ui.server_extension import (
     A2UI_MIME_TYPE,
     A2UI_STANDARD_CATALOG_ID,
     A2UI_V09_BASIC_CATALOG_ID,
 )
-from crewai.a2a.extensions.a2ui.v0_9 import extract_a2ui_v09_json_objects
-from crewai.a2a.extensions.a2ui.validator import (
+from crewai_a2a.extensions.a2ui.v0_9 import extract_a2ui_v09_json_objects
+from crewai_a2a.extensions.a2ui.validator import (
     A2UIValidationError,
     validate_a2ui_message,
     validate_a2ui_message_v09,
@@ -30,7 +30,6 @@ from crewai.a2a.extensions.a2ui.validator import (
 
 if TYPE_CHECKING:
     from a2a.types import Message
-
     from crewai.agent.core import Agent
 
 

lib/crewai-a2a/src/crewai_a2a/extensions/a2ui/prompt.py

@@ -4,13 +4,13 @@ from __future__ import annotations
 
 import json
 
-from crewai.a2a.extensions.a2ui.catalog import STANDARD_CATALOG_COMPONENTS
-from crewai.a2a.extensions.a2ui.schema import load_schema
-from crewai.a2a.extensions.a2ui.server_extension import (
+from crewai_a2a.extensions.a2ui.catalog import STANDARD_CATALOG_COMPONENTS
+from crewai_a2a.extensions.a2ui.schema import load_schema
+from crewai_a2a.extensions.a2ui.server_extension import (
     A2UI_EXTENSION_URI,
     A2UI_V09_BASIC_CATALOG_ID,
 )
-from crewai.a2a.extensions.a2ui.v0_9 import (
+from crewai_a2a.extensions.a2ui.v0_9 import (
     BASIC_CATALOG_COMPONENTS as V09_CATALOG_COMPONENTS,
     BASIC_CATALOG_FUNCTIONS,
 )

lib/crewai-a2a/src/crewai_a2a/extensions/a2ui/server_extension.py

@@ -5,16 +5,16 @@ from __future__ import annotations
 import logging
 from typing import Any
 
-from crewai.a2a.extensions.a2ui.models import A2UIResponse, extract_a2ui_json_objects
-from crewai.a2a.extensions.a2ui.v0_9 import (
+from crewai_a2a.extensions.a2ui.models import A2UIResponse, extract_a2ui_json_objects
+from crewai_a2a.extensions.a2ui.v0_9 import (
     extract_a2ui_v09_json_objects,
 )
-from crewai.a2a.extensions.a2ui.validator import (
+from crewai_a2a.extensions.a2ui.validator import (
     A2UIValidationError,
     validate_a2ui_message,
     validate_a2ui_message_v09,
 )
-from crewai.a2a.extensions.server import ExtensionContext, ServerExtension
+from crewai_a2a.extensions.server import ExtensionContext, ServerExtension
 
 
 logger = logging.getLogger(__name__)

lib/crewai-a2a/src/crewai_a2a/extensions/a2ui/validator.py

@@ -6,7 +6,7 @@ from typing import Any
 
 from pydantic import BaseModel, ValidationError
 
-from crewai.a2a.extensions.a2ui.catalog import (
+from crewai_a2a.extensions.a2ui.catalog import (
     AudioPlayer,
     Button,
     Card,
@@ -26,8 +26,8 @@ from crewai.a2a.extensions.a2ui.catalog import (
     TextField,
     Video,
 )
-from crewai.a2a.extensions.a2ui.models import A2UIEvent, A2UIMessage
-from crewai.a2a.extensions.a2ui.v0_9 import (
+from crewai_a2a.extensions.a2ui.models import A2UIEvent, A2UIMessage
+from crewai_a2a.extensions.a2ui.v0_9 import (
     A2UIEventV09,
     A2UIMessageV09,
     AudioPlayerV09,

lib/crewai-a2a/src/crewai_a2a/extensions/base.py

@@ -19,7 +19,6 @@ from pydantic import BeforeValidator
 
 if TYPE_CHECKING:
     from a2a.types import Message
-
     from crewai.agent.core import Agent
 
 
@@ -63,25 +62,21 @@ class A2AExtension(Protocol):
     Example:
         class MyExtension:
             def inject_tools(self, agent: Agent) -> None:
-                # Add custom tools to the agent
                 pass
 
             def extract_state_from_history(
                 self, conversation_history: Sequence[Message]
             ) -> ConversationState | None:
-                # Extract state from conversation
                 return None
 
             def augment_prompt(
                 self, base_prompt: str, conversation_state: ConversationState | None
             ) -> str:
-                # Add custom instructions
                 return base_prompt
 
             def process_response(
                 self, agent_response: Any, conversation_state: ConversationState | None
             ) -> Any:
-                # Modify response if needed
                 return agent_response
     """
 

lib/crewai-a2a/src/crewai_a2a/extensions/registry.py

@@ -18,8 +18,8 @@ from a2a.extensions.common import (
 )
 from a2a.types import AgentCard, AgentExtension
 
-from crewai.a2a.config import A2AClientConfig, A2AConfig
-from crewai.a2a.extensions.base import ExtensionRegistry
+from crewai_a2a.config import A2AClientConfig, A2AConfig
+from crewai_a2a.extensions.base import ExtensionRegistry
 
 
 def get_extensions_from_config(

lib/crewai-a2a/src/crewai_a2a/task_helpers.py

@@ -18,13 +18,12 @@ from a2a.types import (
     TaskStatusUpdateEvent,
     TextPart,
 )
-from typing_extensions import NotRequired, TypedDict
-
 from crewai.events.event_bus import crewai_event_bus
 from crewai.events.types.a2a_events import (
     A2AConnectionErrorEvent,
     A2AResponseReceivedEvent,
 )
+from typing_extensions import NotRequired, TypedDict
 
 
 if TYPE_CHECKING:

lib/crewai-a2a/src/crewai_a2a/types.py

@@ -15,7 +15,7 @@ from typing_extensions import NotRequired, TypedDict
 
 
 try:
-    from crewai.a2a.updates import (
+    from crewai_a2a.updates import (
         PollingConfig,
         PollingHandler,
         PushNotificationConfig,

lib/crewai-a2a/src/crewai_a2a/updates/__init__.py

@@ -1,6 +1,6 @@
 """A2A update mechanism configuration types."""
 
-from crewai.a2a.updates.base import (
+from crewai_a2a.updates.base import (
     BaseHandlerKwargs,
     PollingHandlerKwargs,
     PushNotificationHandlerKwargs,
@@ -8,12 +8,12 @@ from crewai.a2a.updates.base import (
     StreamingHandlerKwargs,
     UpdateHandler,
 )
-from crewai.a2a.updates.polling.config import PollingConfig
-from crewai.a2a.updates.polling.handler import PollingHandler
-from crewai.a2a.updates.push_notifications.config import PushNotificationConfig
-from crewai.a2a.updates.push_notifications.handler import PushNotificationHandler
-from crewai.a2a.updates.streaming.config import StreamingConfig
-from crewai.a2a.updates.streaming.handler import StreamingHandler
+from crewai_a2a.updates.polling.config import PollingConfig
+from crewai_a2a.updates.polling.handler import PollingHandler
+from crewai_a2a.updates.push_notifications.config import PushNotificationConfig
+from crewai_a2a.updates.push_notifications.handler import PushNotificationHandler
+from crewai_a2a.updates.streaming.config import StreamingConfig
+from crewai_a2a.updates.streaming.handler import StreamingHandler
 
 
 UpdateConfig = PollingConfig | StreamingConfig | PushNotificationConfig

lib/crewai-a2a/src/crewai_a2a/updates/base.py

@@ -29,8 +29,8 @@ if TYPE_CHECKING:
     from a2a.client import Client
     from a2a.types import AgentCard, Message, Task
 
-    from crewai.a2a.task_helpers import TaskStateResult
-    from crewai.a2a.updates.push_notifications.config import PushNotificationConfig
+    from crewai_a2a.task_helpers import TaskStateResult
+    from crewai_a2a.updates.push_notifications.config import PushNotificationConfig
 
 
 class BaseHandlerKwargs(TypedDict, total=False):

lib/crewai-a2a/src/crewai_a2a/updates/polling/handler.py

@@ -18,17 +18,6 @@ from a2a.types import (
     TaskState,
     TextPart,
 )
-from typing_extensions import Unpack
-
-from crewai.a2a.errors import A2APollingTimeoutError
-from crewai.a2a.task_helpers import (
-    ACTIONABLE_STATES,
-    TERMINAL_STATES,
-    TaskStateResult,
-    process_task_state,
-    send_message_and_get_task_id,
-)
-from crewai.a2a.updates.base import PollingHandlerKwargs
 from crewai.events.event_bus import crewai_event_bus
 from crewai.events.types.a2a_events import (
     A2AConnectionErrorEvent,
@@ -36,6 +25,17 @@ from crewai.events.types.a2a_events import (
     A2APollingStatusEvent,
     A2AResponseReceivedEvent,
 )
+from typing_extensions import Unpack
+
+from crewai_a2a.errors import A2APollingTimeoutError
+from crewai_a2a.task_helpers import (
+    ACTIONABLE_STATES,
+    TERMINAL_STATES,
+    TaskStateResult,
+    process_task_state,
+    send_message_and_get_task_id,
+)
+from crewai_a2a.updates.base import PollingHandlerKwargs
 
 
 if TYPE_CHECKING:

lib/crewai-a2a/src/crewai_a2a/updates/push_notifications/config.py

@@ -7,8 +7,8 @@ from typing import Annotated
 from a2a.types import PushNotificationAuthenticationInfo
 from pydantic import AnyHttpUrl, BaseModel, BeforeValidator, Field
 
-from crewai.a2a.updates.base import PushNotificationResultStore
-from crewai.a2a.updates.push_notifications.signature import WebhookSignatureConfig
+from crewai_a2a.updates.base import PushNotificationResultStore
+from crewai_a2a.updates.push_notifications.signature import WebhookSignatureConfig
 
 
 def _coerce_signature(

lib/crewai-a2a/src/crewai_a2a/updates/push_notifications/handler.py

@@ -16,19 +16,6 @@ from a2a.types import (
     TaskState,
     TextPart,
 )
-from typing_extensions import Unpack
-
-from crewai.a2a.task_helpers import (
-    TaskStateResult,
-    process_task_state,
-    send_message_and_get_task_id,
-)
-from crewai.a2a.updates.base import (
-    CommonParams,
-    PushNotificationHandlerKwargs,
-    PushNotificationResultStore,
-    extract_common_params,
-)
 from crewai.events.event_bus import crewai_event_bus
 from crewai.events.types.a2a_events import (
     A2AConnectionErrorEvent,
@@ -36,6 +23,19 @@ from crewai.events.types.a2a_events import (
     A2APushNotificationTimeoutEvent,
     A2AResponseReceivedEvent,
 )
+from typing_extensions import Unpack
+
+from crewai_a2a.task_helpers import (
+    TaskStateResult,
+    process_task_state,
+    send_message_and_get_task_id,
+)
+from crewai_a2a.updates.base import (
+    CommonParams,
+    PushNotificationHandlerKwargs,
+    PushNotificationResultStore,
+    extract_common_params,
+)
 
 
 if TYPE_CHECKING:

lib/crewai-a2a/src/crewai_a2a/updates/streaming/handler.py

@@ -22,18 +22,6 @@ from a2a.types import (
     TaskStatusUpdateEvent,
     TextPart,
 )
-from typing_extensions import Unpack
-
-from crewai.a2a.task_helpers import (
-    ACTIONABLE_STATES,
-    TERMINAL_STATES,
-    TaskStateResult,
-    process_task_state,
-)
-from crewai.a2a.updates.base import StreamingHandlerKwargs, extract_common_params
-from crewai.a2a.updates.streaming.params import (
-    process_status_update,
-)
 from crewai.events.event_bus import crewai_event_bus
 from crewai.events.types.a2a_events import (
     A2AArtifactReceivedEvent,
@@ -42,6 +30,18 @@ from crewai.events.types.a2a_events import (
     A2AStreamingChunkEvent,
     A2AStreamingStartedEvent,
 )
+from typing_extensions import Unpack
+
+from crewai_a2a.task_helpers import (
+    ACTIONABLE_STATES,
+    TERMINAL_STATES,
+    TaskStateResult,
+    process_task_state,
+)
+from crewai_a2a.updates.base import StreamingHandlerKwargs, extract_common_params
+from crewai_a2a.updates.streaming.params import (
+    process_status_update,
+)
 
 
 logger = logging.getLogger(__name__)

lib/crewai-a2a/src/crewai_a2a/utils/agent_card.py

@@ -16,15 +16,6 @@ from a2a.client.errors import A2AClientHTTPError
 from a2a.types import AgentCapabilities, AgentCard, AgentSkill
 from aiocache import cached  # type: ignore[import-untyped]
 from aiocache.serializers import PickleSerializer  # type: ignore[import-untyped]
-import httpx
-
-from crewai.a2a.auth.client_schemes import APIKeyAuth, HTTPDigestAuth
-from crewai.a2a.auth.utils import (
-    _auth_store,
-    configure_auth_client,
-    retry_on_401,
-)
-from crewai.a2a.config import A2AServerConfig
 from crewai.crew import Crew
 from crewai.events.event_bus import crewai_event_bus
 from crewai.events.types.a2a_events import (
@@ -32,13 +23,23 @@ from crewai.events.types.a2a_events import (
     A2AAuthenticationFailedEvent,
     A2AConnectionErrorEvent,
 )
+import httpx
+
+from crewai_a2a.auth.client_schemes import APIKeyAuth, HTTPDigestAuth
+from crewai_a2a.auth.utils import (
+    _auth_store,
+    configure_auth_client,
+    retry_on_401,
+)
+from crewai_a2a.config import A2AServerConfig
 
 
 if TYPE_CHECKING:
-    from crewai.a2a.auth.client_schemes import ClientAuthScheme
     from crewai.agent import Agent
     from crewai.task import Task
 
+    from crewai_a2a.auth.client_schemes import ClientAuthScheme
+
 
 def _get_tls_verify(auth: ClientAuthScheme | None) -> ssl.SSLContext | bool | str:
     """Get TLS verify parameter from auth scheme.
@@ -495,7 +496,7 @@ def _agent_to_agent_card(agent: Agent, url: str) -> AgentCard:
     Returns:
         AgentCard describing the agent's capabilities.
     """
-    from crewai.a2a.utils.agent_card_signing import sign_agent_card
+    from crewai_a2a.utils.agent_card_signing import sign_agent_card
 
     server_config = _get_server_config(agent) or A2AServerConfig()
 
@@ -529,7 +530,7 @@ def _agent_to_agent_card(agent: Agent, url: str) -> AgentCard:
 
     capabilities = server_config.capabilities
     if server_config.server_extensions:
-        from crewai.a2a.extensions.server import ServerExtensionRegistry
+        from crewai_a2a.extensions.server import ServerExtensionRegistry
 
         registry = ServerExtensionRegistry(server_config.server_extensions)
         ext_list = registry.get_agent_extensions()

lib/crewai-a2a/src/crewai_a2a/utils/agent_card_signing.py

@@ -5,7 +5,7 @@ JSON Web Signatures (JWS) as per RFC 7515. Signed agent cards allow clients
 to verify the authenticity and integrity of agent card information.
 
 Example:
-    >>> from crewai.a2a.utils.agent_card_signing import sign_agent_card
+    >>> from crewai_a2a.utils.agent_card_signing import sign_agent_card
     >>> signature = sign_agent_card(agent_card, private_key_pem, key_id="key-1")
     >>> card_with_sig = card.model_copy(update={"signatures": [signature]})
 """

lib/crewai-a2a/src/crewai_a2a/utils/content_type.py

@@ -10,7 +10,6 @@ from dataclasses import dataclass
 from typing import TYPE_CHECKING, Annotated, Final, Literal, cast
 
 from a2a.types import Part
-
 from crewai.events.event_bus import crewai_event_bus
 from crewai.events.types.a2a_events import A2AContentTypeNegotiatedEvent
 

lib/crewai-a2a/src/crewai_a2a/utils/delegation.py

@@ -23,48 +23,6 @@ from a2a.types import (
     Role,
     TextPart,
 )
-import httpx
-from pydantic import BaseModel
-
-from crewai.a2a.auth.client_schemes import APIKeyAuth, HTTPDigestAuth
-from crewai.a2a.auth.utils import (
-    _auth_store,
-    configure_auth_client,
-    validate_auth_against_agent_card,
-)
-from crewai.a2a.config import ClientTransportConfig, GRPCClientConfig
-from crewai.a2a.extensions.registry import (
-    ExtensionsMiddleware,
-    validate_required_extensions,
-)
-from crewai.a2a.task_helpers import TaskStateResult
-from crewai.a2a.types import (
-    HANDLER_REGISTRY,
-    HandlerType,
-    PartsDict,
-    PartsMetadataDict,
-    TransportType,
-)
-from crewai.a2a.updates import (
-    PollingConfig,
-    PushNotificationConfig,
-    StreamingHandler,
-    UpdateConfig,
-)
-from crewai.a2a.utils.agent_card import (
-    _afetch_agent_card_cached,
-    _get_tls_verify,
-    _prepare_auth_headers,
-)
-from crewai.a2a.utils.content_type import (
-    DEFAULT_CLIENT_OUTPUT_MODES,
-    negotiate_content_types,
-)
-from crewai.a2a.utils.transport import (
-    NegotiatedTransport,
-    TransportNegotiationError,
-    negotiate_transport,
-)
 from crewai.events.event_bus import crewai_event_bus
 from crewai.events.types.a2a_events import (
     A2AConversationStartedEvent,
@@ -72,6 +30,48 @@ from crewai.events.types.a2a_events import (
     A2ADelegationStartedEvent,
     A2AMessageSentEvent,
 )
+import httpx
+from pydantic import BaseModel
+
+from crewai_a2a.auth.client_schemes import APIKeyAuth, HTTPDigestAuth
+from crewai_a2a.auth.utils import (
+    _auth_store,
+    configure_auth_client,
+    validate_auth_against_agent_card,
+)
+from crewai_a2a.config import ClientTransportConfig, GRPCClientConfig
+from crewai_a2a.extensions.registry import (
+    ExtensionsMiddleware,
+    validate_required_extensions,
+)
+from crewai_a2a.task_helpers import TaskStateResult
+from crewai_a2a.types import (
+    HANDLER_REGISTRY,
+    HandlerType,
+    PartsDict,
+    PartsMetadataDict,
+    TransportType,
+)
+from crewai_a2a.updates import (
+    PollingConfig,
+    PushNotificationConfig,
+    StreamingHandler,
+    UpdateConfig,
+)
+from crewai_a2a.utils.agent_card import (
+    _afetch_agent_card_cached,
+    _get_tls_verify,
+    _prepare_auth_headers,
+)
+from crewai_a2a.utils.content_type import (
+    DEFAULT_CLIENT_OUTPUT_MODES,
+    negotiate_content_types,
+)
+from crewai_a2a.utils.transport import (
+    NegotiatedTransport,
+    TransportNegotiationError,
+    negotiate_transport,
+)
 
 
 logger = logging.getLogger(__name__)
@@ -80,7 +80,7 @@ logger = logging.getLogger(__name__)
 if TYPE_CHECKING:
     from a2a.types import Message
 
-    from crewai.a2a.auth.client_schemes import ClientAuthScheme
+    from crewai_a2a.auth.client_schemes import ClientAuthScheme
 
 
 _DEFAULT_TRANSPORT: Final[TransportType] = "JSONRPC"
@@ -771,7 +771,7 @@ def _create_grpc_channel_factory(
     auth_metadata: list[tuple[str, str]] = []
 
     if auth is not None:
-        from crewai.a2a.auth.client_schemes import (
+        from crewai_a2a.auth.client_schemes import (
             APIKeyAuth,
             BearerTokenAuth,
             HTTPBasicAuth,

lib/crewai-a2a/src/crewai_a2a/utils/logging.py

@@ -103,7 +103,7 @@ class LogContext:
         _log_context.reset(self._token)
 
 
-def configure_json_logging(logger_name: str = "crewai.a2a") -> None:
+def configure_json_logging(logger_name: str = "crewai_a2a") -> None:
     """Configure JSON logging for the A2A module.
 
     Args:

lib/crewai-a2a/src/crewai_a2a/utils/response_model.py

@@ -4,10 +4,10 @@ from __future__ import annotations
 
 from typing import TypeAlias
 
+from crewai.types.utils import create_literals_from_strings
 from pydantic import BaseModel, Field, create_model
 
-from crewai.a2a.config import A2AClientConfig, A2AConfig, A2AServerConfig
-from crewai.types.utils import create_literals_from_strings
+from crewai_a2a.config import A2AClientConfig, A2AConfig, A2AServerConfig
 
 
 A2AConfigTypes: TypeAlias = A2AConfig | A2AServerConfig | A2AClientConfig
@@ -77,7 +77,6 @@ def extract_a2a_agent_ids_from_config(
     else:
         configs = a2a_config
 
-    # Filter to only client configs (those with endpoint)
     client_configs: list[A2AClientConfigTypes] = [
         config for config in configs if isinstance(config, (A2AConfig, A2AClientConfig))
     ]

lib/crewai-a2a/src/crewai_a2a/utils/task.py

@@ -37,11 +37,6 @@ from a2a.utils import (
 )
 from a2a.utils.errors import ServerError
 from aiocache import SimpleMemoryCache, caches  # type: ignore[import-untyped]
-from pydantic import BaseModel
-from typing_extensions import TypedDict
-
-from crewai.a2a.utils.agent_card import _get_server_config
-from crewai.a2a.utils.content_type import validate_message_parts
 from crewai.events.event_bus import crewai_event_bus
 from crewai.events.types.a2a_events import (
     A2AServerTaskCanceledEvent,
@@ -51,12 +46,18 @@ from crewai.events.types.a2a_events import (
 )
 from crewai.task import Task
 from crewai.utilities.pydantic_schema_utils import create_model_from_schema
+from pydantic import BaseModel
+from typing_extensions import TypedDict
+
+from crewai_a2a.utils.agent_card import _get_server_config
+from crewai_a2a.utils.content_type import validate_message_parts
 
 
 if TYPE_CHECKING:
-    from crewai.a2a.extensions.server import ExtensionContext, ServerExtensionRegistry
     from crewai.agent import Agent
 
+    from crewai_a2a.extensions.server import ExtensionContext, ServerExtensionRegistry
+
 
 logger = logging.getLogger(__name__)
 

lib/crewai-a2a/src/crewai_a2a/utils/transport.py

@@ -11,7 +11,6 @@ from dataclasses import dataclass
 from typing import Final, Literal
 
 from a2a.types import AgentCard, AgentInterface
-
 from crewai.events.event_bus import crewai_event_bus
 from crewai.events.types.a2a_events import A2ATransportNegotiatedEvent
 

lib/crewai-a2a/src/crewai_a2a/wrapper.py

@@ -15,33 +15,6 @@ from types import MethodType
 from typing import TYPE_CHECKING, Any, NamedTuple
 
 from a2a.types import Role, TaskState
-from pydantic import BaseModel, ValidationError
-
-from crewai.a2a.config import A2AClientConfig, A2AConfig
-from crewai.a2a.extensions.base import (
-    A2AExtension,
-    ConversationState,
-    ExtensionRegistry,
-)
-from crewai.a2a.task_helpers import TaskStateResult
-from crewai.a2a.templates import (
-    AVAILABLE_AGENTS_TEMPLATE,
-    CONVERSATION_TURN_INFO_TEMPLATE,
-    PREVIOUS_A2A_CONVERSATION_TEMPLATE,
-    REMOTE_AGENT_RESPONSE_NOTICE,
-    UNAVAILABLE_AGENTS_NOTICE_TEMPLATE,
-)
-from crewai.a2a.types import AgentResponseProtocol
-from crewai.a2a.utils.agent_card import (
-    afetch_agent_card,
-    fetch_agent_card,
-    inject_a2a_server_methods,
-)
-from crewai.a2a.utils.delegation import (
-    aexecute_a2a_delegation,
-    execute_a2a_delegation,
-)
-from crewai.a2a.utils.response_model import get_a2a_agents_and_response_model
 from crewai.events.event_bus import crewai_event_bus
 from crewai.events.types.a2a_events import (
     A2AConversationCompletedEvent,
@@ -49,11 +22,37 @@ from crewai.events.types.a2a_events import (
 )
 from crewai.lite_agent_output import LiteAgentOutput
 from crewai.task import Task
+from pydantic import BaseModel, ValidationError
+
+from crewai_a2a.config import A2AClientConfig, A2AConfig
+from crewai_a2a.extensions.base import (
+    A2AExtension,
+    ConversationState,
+    ExtensionRegistry,
+)
+from crewai_a2a.task_helpers import TaskStateResult
+from crewai_a2a.templates import (
+    AVAILABLE_AGENTS_TEMPLATE,
+    CONVERSATION_TURN_INFO_TEMPLATE,
+    PREVIOUS_A2A_CONVERSATION_TEMPLATE,
+    REMOTE_AGENT_RESPONSE_NOTICE,
+    UNAVAILABLE_AGENTS_NOTICE_TEMPLATE,
+)
+from crewai_a2a.types import AgentResponseProtocol
+from crewai_a2a.utils.agent_card import (
+    afetch_agent_card,
+    fetch_agent_card,
+    inject_a2a_server_methods,
+)
+from crewai_a2a.utils.delegation import (
+    aexecute_a2a_delegation,
+    execute_a2a_delegation,
+)
+from crewai_a2a.utils.response_model import get_a2a_agents_and_response_model
 
 
 if TYPE_CHECKING:
     from a2a.types import AgentCard, Message
-
     from crewai.agent.core import Agent
     from crewai.tools.base_tool import BaseTool
 

lib/crewai-a2a/tests/a2a/extensions/test_a2ui_schema_conformance.py

@@ -9,12 +9,11 @@ from __future__ import annotations
 
 from typing import Any
 
-import jsonschema
-import pytest
-
 from crewai.a2a.extensions.a2ui import catalog
 from crewai.a2a.extensions.a2ui.models import A2UIEvent, A2UIMessage
 from crewai.a2a.extensions.a2ui.schema import load_schema
+import jsonschema
+import pytest
 
 
 SERVER_SCHEMA = load_schema("server_to_client")
@@ -206,7 +205,10 @@ VALID_COMPONENTS: dict[str, dict[str, Any]] = {
     "Divider": {"axis": "horizontal"},
     "Modal": {"entryPointChild": "trigger", "contentChild": "body"},
     "Button": {"child": "label", "action": {"name": "go"}},
-    "CheckBox": {"label": {"literalString": "Accept"}, "value": {"literalBoolean": False}},
+    "CheckBox": {
+        "label": {"literalString": "Accept"},
+        "value": {"literalBoolean": False},
+    },
     "TextField": {"label": {"literalString": "Name"}},
     "DateTimeInput": {"value": {"path": "/date"}},
     "MultipleChoice": {

lib/crewai-a2a/tests/a2a/test_a2a_integration.py

@@ -3,14 +3,12 @@ from __future__ import annotations
 import os
 import uuid
 
-import pytest
-import pytest_asyncio
-
 from a2a.client import ClientFactory
-from a2a.types import AgentCard, Message, Part, Role, TaskState, TextPart
-
+from a2a.types import AgentCard, Message, Part, Role, Task, TaskState, TextPart
 from crewai.a2a.updates.polling.handler import PollingHandler
 from crewai.a2a.updates.streaming.handler import StreamingHandler
+import pytest
+import pytest_asyncio
 
 
 A2A_TEST_ENDPOINT = os.getenv("A2A_TEST_ENDPOINT", "http://localhost:9999")
@@ -162,7 +160,7 @@ class TestA2APushNotificationHandler:
         )
 
     @pytest.fixture
-    def mock_task(self) -> "Task":
+    def mock_task(self) -> Task:
         """Create a minimal valid task for testing."""
         from a2a.types import Task, TaskStatus
 
@@ -182,10 +180,11 @@ class TestA2APushNotificationHandler:
         from unittest.mock import AsyncMock, MagicMock
 
         from a2a.types import Task, TaskStatus
-        from pydantic import AnyHttpUrl
-
         from crewai.a2a.updates.push_notifications.config import PushNotificationConfig
-        from crewai.a2a.updates.push_notifications.handler import PushNotificationHandler
+        from crewai.a2a.updates.push_notifications.handler import (
+            PushNotificationHandler,
+        )
+        from pydantic import AnyHttpUrl
 
         completed_task = Task(
             id="task-123",
@@ -246,10 +245,11 @@ class TestA2APushNotificationHandler:
         from unittest.mock import AsyncMock, MagicMock
 
         from a2a.types import Task, TaskStatus
-        from pydantic import AnyHttpUrl
-
         from crewai.a2a.updates.push_notifications.config import PushNotificationConfig
-        from crewai.a2a.updates.push_notifications.handler import PushNotificationHandler
+        from crewai.a2a.updates.push_notifications.handler import (
+            PushNotificationHandler,
+        )
+        from pydantic import AnyHttpUrl
 
         mock_store = MagicMock()
         mock_store.wait_for_result = AsyncMock(return_value=None)
@@ -303,7 +303,9 @@ class TestA2APushNotificationHandler:
         """Test that push handler fails gracefully without config."""
         from unittest.mock import MagicMock
 
-        from crewai.a2a.updates.push_notifications.handler import PushNotificationHandler
+        from crewai.a2a.updates.push_notifications.handler import (
+            PushNotificationHandler,
+        )
 
         mock_client = MagicMock()
 

lib/crewai-a2a/tests/a2a/utils/test_agent_card.py

@@ -3,7 +3,6 @@
 from __future__ import annotations
 
 from a2a.types import AgentCard, AgentSkill
-
 from crewai import Agent
 from crewai.a2a.config import A2AClientConfig, A2AServerConfig
 from crewai.a2a.utils.agent_card import inject_a2a_server_methods

lib/crewai-a2a/tests/a2a/utils/test_task.py

@@ -6,13 +6,12 @@ import asyncio
 from typing import Any
 from unittest.mock import AsyncMock, MagicMock, patch
 
-import pytest
-import pytest_asyncio
 from a2a.server.agent_execution import RequestContext
 from a2a.server.events import EventQueue
 from a2a.types import Message, Task as A2ATask, TaskState, TaskStatus
-
 from crewai.a2a.utils.task import cancel, cancellable, execute
+import pytest
+import pytest_asyncio
 
 
 @pytest.fixture
@@ -85,8 +84,11 @@ class TestCancellableDecorator:
         assert call_count == 1
 
     @pytest.mark.asyncio
-    async def test_executes_function_with_context(self, mock_context: MagicMock) -> None:
+    async def test_executes_function_with_context(
+        self, mock_context: MagicMock
+    ) -> None:
         """Function executes normally with RequestContext when not cancelled."""
+
         @cancellable
         async def my_func(context: RequestContext) -> str:
             await asyncio.sleep(0.01)
@@ -134,6 +136,7 @@ class TestCancellableDecorator:
     @pytest.mark.asyncio
     async def test_extracts_context_from_kwargs(self, mock_context: MagicMock) -> None:
         """Context can be passed as keyword argument."""
+
         @cancellable
         async def my_func(value: int, context: RequestContext | None = None) -> int:
             return value + 1
@@ -354,6 +357,7 @@ class TestExecuteAndCancelIntegration:
         mock_task: MagicMock,
     ) -> None:
         """Calling cancel stops a running execute."""
+
         async def slow_task(**kwargs: Any) -> str:
             await asyncio.sleep(2.0)
             return "should not complete"
@@ -372,4 +376,4 @@ class TestExecuteAndCancelIntegration:
             await cancel(mock_context, mock_event_queue)
 
             with pytest.raises(asyncio.CancelledError):
-                await execute_task
+                await execute_task

lib/crewai-a2a/tests/agents/test_a2a_trust_completion_status.py

@@ -2,9 +2,9 @@
 
 from unittest.mock import MagicMock, patch
 
+from crewai.a2a.config import A2AConfig
 import pytest
 
-from crewai.a2a.config import A2AConfig
 
 try:
     from a2a.types import Message, Role
@@ -27,9 +27,8 @@ def _create_mock_agent_card(name: str = "Test", url: str = "http://test-endpoint
 @pytest.mark.skipif(not A2A_SDK_INSTALLED, reason="Requires a2a-sdk to be installed")
 def test_trust_remote_completion_status_true_returns_directly():
     """When trust_remote_completion_status=True and A2A returns completed, return result directly."""
-    from crewai.a2a.wrapper import _delegate_to_a2a
-    from crewai.a2a.types import AgentResponseProtocol
     from crewai import Agent, Task
+    from crewai.a2a.wrapper import _delegate_to_a2a
 
     a2a_config = A2AConfig(
         endpoint="http://test-endpoint.com",
@@ -83,8 +82,8 @@ def test_trust_remote_completion_status_true_returns_directly():
 @pytest.mark.skipif(not A2A_SDK_INSTALLED, reason="Requires a2a-sdk to be installed")
 def test_trust_remote_completion_status_false_continues_conversation():
     """When trust_remote_completion_status=False and A2A returns completed, ask server agent."""
-    from crewai.a2a.wrapper import _delegate_to_a2a
     from crewai import Agent, Task
+    from crewai.a2a.wrapper import _delegate_to_a2a
 
     a2a_config = A2AConfig(
         endpoint="http://test-endpoint.com",
@@ -152,4 +151,4 @@ def test_default_trust_remote_completion_status_is_false():
         endpoint="http://test-endpoint.com",
     )
 
-    assert a2a_config.trust_remote_completion_status is False
+    assert a2a_config.trust_remote_completion_status is False

lib/crewai-a2a/tests/agents/test_agent_a2a_kickoff.py

@@ -4,10 +4,9 @@ from __future__ import annotations
 
 import os
 
-import pytest
-
 from crewai import Agent
 from crewai.a2a.config import A2AClientConfig
+import pytest
 
 
 A2A_TEST_ENDPOINT = os.getenv(
@@ -50,9 +49,7 @@ class TestAgentA2AKickoff:
 
     @pytest.mark.skip(reason="VCR cassette matching issue with agent card caching")
     @pytest.mark.vcr()
-    def test_agent_kickoff_with_calculator_skill(
-        self, researcher_agent: Agent
-    ) -> None:
+    def test_agent_kickoff_with_calculator_skill(self, researcher_agent: Agent) -> None:
         """Test that agent can delegate calculation to A2A server."""
         result = researcher_agent.kickoff(
             "Ask the remote A2A agent to calculate 25 times 17."
@@ -149,9 +146,7 @@ class TestAgentA2AKickoff:
 
     @pytest.mark.skip(reason="VCR cassette matching issue with agent card caching")
     @pytest.mark.vcr()
-    def test_agent_kickoff_with_list_messages(
-        self, researcher_agent: Agent
-    ) -> None:
+    def test_agent_kickoff_with_list_messages(self, researcher_agent: Agent) -> None:
         """Test that agent.kickoff() works with list of messages."""
         messages = [
             {

lib/crewai-a2a/tests/agents/test_agent_a2a_wrapping.py

@@ -1,14 +1,12 @@
 """Test A2A wrapper is only applied when a2a is passed to Agent."""
 
-from unittest.mock import patch
-
-import pytest
-
 from crewai import Agent
 from crewai.a2a.config import A2AConfig
+import pytest
+
 
 try:
-    import a2a  # noqa: F401
+    import a2a
 
     A2A_SDK_INSTALLED = True
 except ImportError:
@@ -106,6 +104,9 @@ def test_wrapper_is_applied_differently_per_instance():
         a2a=a2a_config,
     )
 
-    assert agent_without_a2a.execute_task.__func__ is not agent_with_a2a.execute_task.__func__
+    assert (
+        agent_without_a2a.execute_task.__func__
+        is not agent_with_a2a.execute_task.__func__
+    )
     assert not hasattr(agent_without_a2a.execute_task, "__wrapped__")
     assert hasattr(agent_with_a2a.execute_task, "__wrapped__")

lib/crewai-files/pyproject.toml

@@ -9,7 +9,7 @@ authors = [
 requires-python = ">=3.10, <3.14"
 dependencies = [
     "Pillow~=12.1.1",
-    "pypdf~=6.9.1",
+    "pypdf~=6.10.0",
     "python-magic>=0.4.27",
     "aiocache~=0.12.3",
     "aiofiles~=24.1.0",

lib/crewai-files/src/crewai_files/__init__.py

@@ -152,4 +152,4 @@ __all__ = [
     "wrap_file_source",
 ]
 
-__version__ = "1.14.2a2"
+__version__ = "1.14.2a3"

lib/crewai-tools/pyproject.toml

@@ -9,8 +9,8 @@ authors = [
 requires-python = ">=3.10, <3.14"
 dependencies = [
     "pytube~=15.0.0",
-    "requests~=2.32.5",
-    "crewai==1.14.2a2",
+    "requests>=2.33.0,<3",
+    "crewai==1.14.2a3",
     "tiktoken~=0.8.0",
     "beautifulsoup4~=4.13.4",
     "python-docx~=1.2.0",

lib/crewai-tools/src/crewai_tools/__init__.py

@@ -305,4 +305,4 @@ __all__ = [
     "ZapierActionTools",
 ]
 
-__version__ = "1.14.2a2"
+__version__ = "1.14.2a3"

lib/crewai/pyproject.toml

@@ -10,7 +10,7 @@ requires-python = ">=3.10, <3.14"
 dependencies = [
     # Core Dependencies
     "pydantic~=2.11.9",
-    "openai>=1.83.0,<3",
+    "openai>=2.0.0,<3",
     "instructor>=1.3.3",
     # Text Processing
     "pdfplumber~=0.11.4",
@@ -40,7 +40,7 @@ dependencies = [
     "pydantic-settings~=2.10.1",
     "httpx~=0.28.1",
     "mcp~=1.26.0",
-    "uv~=0.9.13",
+    "uv~=0.11.6",
     "aiosqlite~=0.21.0",
     "pyyaml~=6.0",
     "aiofiles~=24.1.0",
@@ -55,7 +55,7 @@ Repository = "https://github.com/crewAIInc/crewAI"
 
 [project.optional-dependencies]
 tools = [
-    "crewai-tools==1.14.2a2",
+    "crewai-tools==1.14.2a3",
 ]
 embeddings = [
     "tiktoken~=0.8.0"
@@ -99,10 +99,7 @@ anthropic = [
     "anthropic~=0.73.0",
 ]
 a2a = [
-     "a2a-sdk~=0.3.10",
-     "httpx-auth~=0.23.1",
-     "httpx-sse~=0.4.0",
-     "aiocache[redis,memcached]~=0.12.3",
+    "crewai-a2a",
 ]
 file-processing = [
     "crewai-files",
@@ -140,6 +137,7 @@ torchvision = [
   { index = "pytorch", marker = "python_version < '3.13'" },
 ]
 crewai-files = { workspace = true }
+crewai-a2a = { workspace = true }
 
 
 [build-system]

lib/crewai/src/crewai/__init__.py

@@ -46,7 +46,7 @@ def _suppress_pydantic_deprecation_warnings() -> None:
 
 _suppress_pydantic_deprecation_warnings()
 
-__version__ = "1.14.2a2"
+__version__ = "1.14.2a3"
 _telemetry_submitted = False
 
 

lib/crewai/src/crewai/a2a/__init__.py

@@ -1,10 +1,57 @@
-"""Agent-to-Agent (A2A) protocol communication module for CrewAI."""
+"""Compatibility shim: ``crewai.a2a`` re-exports :mod:`crewai_a2a`.
 
-from crewai.a2a.config import A2AClientConfig, A2AConfig, A2AServerConfig
+The package lives in the ``crewai-a2a`` distribution (install via the
+``crewai[a2a]`` extra). This module aliases the old import path so existing
+code using ``crewai.a2a.*`` keeps working.
+"""
+
+from __future__ import annotations
+
+from collections.abc import Sequence
+import importlib
+from importlib.abc import Loader, MetaPathFinder
+from importlib.machinery import ModuleSpec
+import sys
+from types import ModuleType
 
 
-__all__ = [
-    "A2AClientConfig",
-    "A2AConfig",
-    "A2AServerConfig",
-]
+try:
+    import crewai_a2a as _crewai_a2a
+except ImportError as exc:
+    raise ImportError(
+        "crewai.a2a requires the 'crewai-a2a' package. "
+        "Install it with: pip install 'crewai[a2a]'"
+    ) from exc
+
+
+class _A2AAliasFinder(MetaPathFinder, Loader):
+    _SRC = "crewai.a2a"
+    _DST = "crewai_a2a"
+
+    def find_spec(
+        self,
+        fullname: str,
+        path: Sequence[str] | None = None,
+        target: ModuleType | None = None,
+    ) -> ModuleSpec | None:
+        if fullname == self._SRC or fullname.startswith(self._SRC + "."):
+            return ModuleSpec(fullname, self)
+        return None
+
+    def create_module(self, spec: ModuleSpec) -> ModuleType:
+        target = self._DST + spec.name[len(self._SRC) :]
+        module = importlib.import_module(target)
+        sys.modules[spec.name] = module
+        return module
+
+    def exec_module(self, module: ModuleType) -> None:
+        return None
+
+
+if not any(isinstance(f, _A2AAliasFinder) for f in sys.meta_path):
+    sys.meta_path.insert(0, _A2AAliasFinder())
+
+for _attr in getattr(_crewai_a2a, "__all__", []):
+    globals()[_attr] = getattr(_crewai_a2a, _attr)
+
+__all__ = list(getattr(_crewai_a2a, "__all__", []))

lib/crewai/src/crewai/a2a/auth/schemas.py

@@ -1,71 +0,0 @@
-"""Deprecated: Authentication schemes for A2A protocol agents.
-
-This module is deprecated. Import from crewai.a2a.auth instead:
-- crewai.a2a.auth.ClientAuthScheme (replaces AuthScheme)
-- crewai.a2a.auth.BearerTokenAuth
-- crewai.a2a.auth.HTTPBasicAuth
-- crewai.a2a.auth.HTTPDigestAuth
-- crewai.a2a.auth.APIKeyAuth
-- crewai.a2a.auth.OAuth2ClientCredentials
-- crewai.a2a.auth.OAuth2AuthorizationCode
-"""
-
-from __future__ import annotations
-
-from typing_extensions import deprecated
-
-from crewai.a2a.auth.client_schemes import (
-    APIKeyAuth as _APIKeyAuth,
-    BearerTokenAuth as _BearerTokenAuth,
-    ClientAuthScheme as _ClientAuthScheme,
-    HTTPBasicAuth as _HTTPBasicAuth,
-    HTTPDigestAuth as _HTTPDigestAuth,
-    OAuth2AuthorizationCode as _OAuth2AuthorizationCode,
-    OAuth2ClientCredentials as _OAuth2ClientCredentials,
-)
-
-
-@deprecated("Use ClientAuthScheme from crewai.a2a.auth instead", category=FutureWarning)
-class AuthScheme(_ClientAuthScheme):
-    """Deprecated: Use ClientAuthScheme from crewai.a2a.auth instead."""
-
-
-@deprecated("Import from crewai.a2a.auth instead", category=FutureWarning)
-class BearerTokenAuth(_BearerTokenAuth):
-    """Deprecated: Import from crewai.a2a.auth instead."""
-
-
-@deprecated("Import from crewai.a2a.auth instead", category=FutureWarning)
-class HTTPBasicAuth(_HTTPBasicAuth):
-    """Deprecated: Import from crewai.a2a.auth instead."""
-
-
-@deprecated("Import from crewai.a2a.auth instead", category=FutureWarning)
-class HTTPDigestAuth(_HTTPDigestAuth):
-    """Deprecated: Import from crewai.a2a.auth instead."""
-
-
-@deprecated("Import from crewai.a2a.auth instead", category=FutureWarning)
-class APIKeyAuth(_APIKeyAuth):
-    """Deprecated: Import from crewai.a2a.auth instead."""
-
-
-@deprecated("Import from crewai.a2a.auth instead", category=FutureWarning)
-class OAuth2ClientCredentials(_OAuth2ClientCredentials):
-    """Deprecated: Import from crewai.a2a.auth instead."""
-
-
-@deprecated("Import from crewai.a2a.auth instead", category=FutureWarning)
-class OAuth2AuthorizationCode(_OAuth2AuthorizationCode):
-    """Deprecated: Import from crewai.a2a.auth instead."""
-
-
-__all__ = [
-    "APIKeyAuth",
-    "AuthScheme",
-    "BearerTokenAuth",
-    "HTTPBasicAuth",
-    "HTTPDigestAuth",
-    "OAuth2AuthorizationCode",
-    "OAuth2ClientCredentials",
-]

lib/crewai/src/crewai/agent/core.py

@@ -1341,7 +1341,6 @@ class Agent(BaseAgent):
 
         raw_tools: list[BaseTool] = self.tools or []
 
-        # Inject memory tools for standalone kickoff (crew path handles its own)
         agent_memory = getattr(self, "memory", None)
         if agent_memory is not None:
             from crewai.tools.memory_tools import create_memory_tools
@@ -1399,7 +1398,6 @@ class Agent(BaseAgent):
         if input_files:
             all_files.update(input_files)
 
-        # Inject memory context for standalone kickoff (recall before execution)
         if agent_memory is not None:
             try:
                 crewai_event_bus.emit(
@@ -1485,8 +1483,6 @@ class Agent(BaseAgent):
         Note:
             For explicit async usage outside of Flow, use kickoff_async() directly.
         """
-        # Magic auto-async: if inside event loop (e.g., inside a Flow),
-        # return coroutine for Flow to await
         if is_inside_event_loop():
             return self.kickoff_async(messages, response_format, input_files)
 
@@ -1637,7 +1633,7 @@ class Agent(BaseAgent):
                 if isinstance(conversion_result, BaseModel):
                     formatted_result = conversion_result
             except ConverterError:
-                pass  # Keep raw output if conversion fails
+                pass
         else:
             raw_output = str(output) if not isinstance(output, str) else output
 
@@ -1719,7 +1715,6 @@ class Agent(BaseAgent):
         elif callable(self.guardrail):
             guardrail_callable = self.guardrail
         else:
-            # Should not happen if called from kickoff with guardrail check
             return output
 
         guardrail_result = process_guardrail(

lib/crewai/src/crewai/agent/planning_config.py

@@ -41,7 +41,6 @@ class PlanningConfig(BaseModel):
         from crewai import Agent
         from crewai.agent.planning_config import PlanningConfig
 
-        # Simple usage — fast, linear execution (default)
         agent = Agent(
             role="Researcher",
             goal="Research topics",
@@ -49,7 +48,6 @@ class PlanningConfig(BaseModel):
             planning_config=PlanningConfig(),
         )
 
-        # Balanced — replan only when steps fail
         agent = Agent(
             role="Researcher",
             goal="Research topics",
@@ -59,7 +57,6 @@ class PlanningConfig(BaseModel):
             ),
         )
 
-        # Full adaptive planning with refinement and replanning
         agent = Agent(
             role="Researcher",
             goal="Research topics",
@@ -69,7 +66,7 @@ class PlanningConfig(BaseModel):
                 max_attempts=3,
                 max_steps=10,
                 plan_prompt="Create a focused plan for: {description}",
-                llm="gpt-4o-mini",  # Use cheaper model for planning
+                llm="gpt-4o-mini",
             ),
         )
         ```

lib/crewai/src/crewai/agent/utils.py

@@ -39,7 +39,6 @@ def handle_reasoning(agent: Agent, task: Task) -> None:
         agent: The agent performing the task.
         task: The task to execute.
     """
-    # Check if planning is enabled using the planning_enabled property
     if not getattr(agent, "planning_enabled", False):
         return