feat: RemoteAgents

.github/CODEOWNERS

@@ -0,0 +1,9 @@
+# AG2 code owners
+# About code owners https://docs.github.com/ru/repositories/managing-your-repositorys-settings-and-features/customizing-your-repository/about-code-owners
+
+# A2A and Remote
+/autogen/a2a/ @Lancetnik
+/autogen/remote/ @Lancetnik
+/test/a2a/ @Lancetnik
+/test/remote/ @Lancetnik
+/website/docs/user-guide/a2a/ @Lancetnik

.github/workflows/claude-code-review.yml

@@ -3,10 +3,22 @@ name: Claude Code Review
 on:
   # For PRs from the same repository (fast path)
   pull_request:
-    types: [opened, synchronize]
+    types:
+      - opened
+      - synchronize
+      - ready_for_review
+    # Optional: Only run on specific file changes
+    # paths:
+    #   - "src/**/*.ts"
+    #   - "src/**/*.tsx"
+    #   - "src/**/*.js"
+    #   - "src/**/*.jsx"
   # For PRs from forked repositories (secure path with secrets)
   pull_request_target:
-    types: [opened, synchronize]
+    types:
+      - opened
+      - synchronize
+      - ready_for_review
 
 jobs:
   claude-review:

.github/workflows/core-test.yml

@@ -80,7 +80,7 @@ jobs:
         shell: bash
       - name: Install packages and dependencies
         run: |
-          uv pip install --system -e .[test,cosmosdb,interop,redis,websockets,openai,docs]
+          uv pip install --system -e .[test,cosmosdb,interop,redis,websockets,openai,docs,a2a]
       - name: Install optional dependencies for code executors
         run: |
           uv pip install --system -e ".[jupyter-executor]"

.gitignore

@@ -1,16 +1,15 @@
 .docusaurus/
 node_modules/
+
 # Project
-/.vs
-.vscode
+.vs/
+.vscode/
+.idea/
+.DS_Store
 
 # Log files
 *.log
 
-# Python virtualenv
-.venv*
-.env*
-
 # Byte-compiled / optimized / DLL files
 __pycache__/
 *.py[cod]
@@ -76,7 +75,7 @@ db.sqlite3-journal
 
 # Flask stuff:
 instance/
-.webassets-cache
+.webassets-cache/
 
 # Scrapy stuff:
 .scrapy
@@ -125,6 +124,8 @@ venv/
 ENV/
 env.bak/
 venv.bak/
+.venv*
+.env*
 
 # Spyder project settings
 .spyderproject
@@ -141,6 +142,9 @@ venv.bak/
 .dmypy.json
 dmypy.json
 
+# ruff
+.ruff_cache/
+
 # Pyre type checker
 .pyre/
 
@@ -150,10 +154,7 @@ dmypy.json
 # Cython debug symbols
 cython_debug/
 
-logs
-
-.idea/*
-.DS_Store
+logs/
 
 output/
 *.pkl
@@ -168,7 +169,7 @@ wolfram.txt
 
 # DB on disk for Teachability
 tmp/
-test/my_tmp/*
+test/my_tmp/
 
 # Storage for the AgentEval output
 test/test_files/agenteval-in-out/out/
@@ -179,28 +180,27 @@ local_cache/
 
 # Files created by tests
 *tmp_code_*
-test/agentchat/test_agent_scripts/*
+test/agentchat/test_agent_scripts/
 
 # test cache
 .cache_test
 .db
 local_cache
 
-
-notebook/result.png
-
-notebook/coding
-
 chroma
 notebook/reasoning_tree.json
 client_secret*.json
 *token*.json
 *credentials.json
 notebook/*_server.py
 
+notebook/result.png
+notebook/coding/
 
-notebook/mcp/wikipedia_articles
-notebook/mcp/arxiv_papers
+notebook/mcp/wikipedia_articles/
+notebook/mcp/arxiv_papers/
 
+remote-examples
 
 *CLAUDE.md:
+.cursor/

MAINTAINERS.md

@@ -2,28 +2,30 @@
 
 ## Here is a list of maintainers for the AG2 project.
 
-| Name            | GitHub Handle                                              | Organization           | Features                                |
-|-----------------|------------------------------------------------------------|------------------------|-----------------------------------------|
-| Qingyun Wu      | [qingyun-wu](https://github.com/qingyun-wu)                | Penn State University  | all, alt-models, autobuilder            |
-| Chi Wang        | [sonichi](https://github.com/sonichi)                      | -                      | all                                     |
-| Mark Sze        | [marklysze](https://github.com/marklysze)                  | -                      | alt-models, group chat                  |
-| Hrushikesh Dokala | [Hk669](https://github.com/Hk669)                        | -                      | alt-models, swebench, logging, rag      |
-| Jiale Liu       | [LeoLjl](https://github.com/LeoLjl)                       | Penn State University  | autobuild, group chat                   |
-| Shaokun Zhang   | [skzhang1](https://github.com/skzhang1)                    | Penn State University  | AgentOptimizer, Teachability            |
-| Yixuan Zhai     | [randombet](https://github.com/randombet)                  | Meta                   | group chat, sequential_chats, rag       |
-| Yiran Wu        | [yiranwu0](https://github.com/yiranwu0)                    | Penn State University  | alt-models, group chat, logging, infra  |
-| Jieyu Zhang     | [JieyuZ2](https://jieyuz2.github.io/)                  | University of Washington | autobuild, group chat       |
-| Davor Runje     | [davorrunje](https://github.com/davorrunje)                | airt.ai                | Tool calling, I/O                        |
-| Rudy Wu     | [rudyalways](https://github.com/rudyalways)                | Google                | all, group chats, sequential chats                |
-| Haiyang Li  | [ohdearquant](https://github.com/ohdearquant)               | -               | all, sequential chats, structured output, low-level|
-| Eric Moore  | [emooreatx](https://github.com/emooreatx)               | IBM               | all|
-| Evan David    | [evandavid1](https://github.com/evandavid1)                | -                      | all |
-| Tvrtko Sternak  | [sternakt](https://github.com/sternakt)               | airt.ai               | structured output |
-| Jiacheng Shang  | [Eric-Shang](https://github.com/Eric-Shang)               | Toast              | RAG |
-| Alec Solder  | [alecsolder](https://github.com/alecsolder)               | -                | swarms, reasoning, function calling |
-| Marc Willhaus | [willhama](https://github.com/willhama)               | -                | - |
-| George Sideris | [giorgossideris](https://github.com/giorgossideris)               | -                | reasoning, RAG |
-| Beibin Li | [BeibinLi](https://github.com/BeibinLi)               | GenAI, Meta               | multimodal, reasoning, optiguide |
+| Name              | GitHub Handle                                              | Organization             | Features                                |
+|-------------------|------------------------------------------------------------|--------------------------|-----------------------------------------|
+| Qingyun Wu        | [qingyun-wu](https://github.com/qingyun-wu)                | Penn State University    | all, alt-models, autobuilder            |
+| Chi Wang          | [sonichi](https://github.com/sonichi)                      | -                        | all                                     |
+| Mark Sze          | [marklysze](https://github.com/marklysze)                  | -                        | alt-models, group chat                  |
+| Hrushikesh Dokala | [Hk669](https://github.com/Hk669)                          | -                        | alt-models, swebench, logging, rag      |
+| Jiale Liu         | [LeoLjl](https://github.com/LeoLjl)                        | Penn State University    | autobuild, group chat                   |
+| Shaokun Zhang     | [skzhang1](https://github.com/skzhang1)                    | Penn State University    | AgentOptimizer, Teachability            |
+| Yixuan Zhai       | [randombet](https://github.com/randombet)                  | Meta                     | group chat, sequential_chats, rag       |
+| Yiran Wu          | [yiranwu0](https://github.com/yiranwu0)                    | Penn State University    | alt-models, group chat, logging, infra  |
+| Jieyu Zhang       | [JieyuZ2](https://jieyuz2.github.io/)                      | University of Washington | autobuild, group chat                   |
+| Davor Runje       | [davorrunje](https://github.com/davorrunje)                | airt.ai                  | Tool calling, I/O                       |
+| Rudy Wu           | [rudyalways](https://github.com/rudyalways)                | Google                   | all, group chats, sequential chats      |
+| Haiyang Li        | [ohdearquant](https://github.com/ohdearquant)              | -                        | all, sequential chats, structured output, low-level|
+| Eric Moore        | [emooreatx](https://github.com/emooreatx)                  | IBM                      | all                                     |
+| Evan David        | [evandavid1](https://github.com/evandavid1)                | -                        | all                                     |
+| Tvrtko Sternak    | [sternakt](https://github.com/sternakt)                    | airt.ai                  | structured output                       |
+| Jiacheng Shang    | [Eric-Shang](https://github.com/Eric-Shang)                | Toast                    | RAG                                     |
+| Alec Solder       | [alecsolder](https://github.com/alecsolder)                | -                        | swarms, reasoning, function calling     |
+| Marc Willhaus     | [willhama](https://github.com/willhama)                    | -                        | -                                       |
+| George Sideris    | [giorgossideris](https://github.com/giorgossideris)        | -                        | reasoning, RAG                          |
+| Beibin Li         | [BeibinLi](https://github.com/BeibinLi)                    | GenAI, Meta              | multimodal, reasoning, optiguide        |
+| Nikita Pastukhov  | [Lancetnik](https://github.com/lancetnik)                  | -                        | A2A                                     |
+
 
 **Pending Maintainers list (Marked with \*, Waiting for explicit approval from the maintainers)**
 | Name            | GitHub Handle                                              | Organization           | Features                                |

autogen/a2a/__init__.py

@@ -0,0 +1,36 @@
+# Copyright (c) 2023 - 2025, AG2ai, Inc., AG2ai open-source projects maintainers and core contributors
+#
+# SPDX-License-Identifier: Apache-2.0
+try:
+    from a2a.types import AgentCard
+except ImportError as e:
+    raise ImportError("a2a-sdk is not installed. Please install it with:\npip install ag2[a2a]") from e
+
+import warnings
+
+warnings.warn(
+    (
+        "AG2 Implementation for A2A support is in experimental mode "
+        "and is subjected to breaking changes. Once it's stable enough the "
+        "experimental mode will be removed. Your feedback is welcome."
+    ),
+    ImportWarning,
+    stacklevel=2,
+)
+
+from autogen.remote.httpx_client_factory import HttpxClientFactory
+
+from .agent_executor import AutogenAgentExecutor
+from .client import A2aRemoteAgent
+from .httpx_client_factory import MockClient
+from .server import A2aAgentServer, CardSettings
+
+__all__ = (
+    "A2aAgentServer",
+    "A2aRemoteAgent",
+    "AgentCard",
+    "AutogenAgentExecutor",
+    "CardSettings",
+    "HttpxClientFactory",
+    "MockClient",
+)

autogen/a2a/agent_executor.py

@@ -0,0 +1,105 @@
+# Copyright (c) 2023 - 2025, AG2ai, Inc., AG2ai open-source projects maintainers and core contributors
+#
+# SPDX-License-Identifier: Apache-2.0
+
+from datetime import datetime, timezone
+
+from a2a.server.agent_execution import AgentExecutor, RequestContext
+from a2a.server.events import EventQueue
+from a2a.types import TaskArtifactUpdateEvent, TaskState, TaskStatus, TaskStatusUpdateEvent
+from a2a.utils import new_task
+from a2a.utils.message import new_agent_text_message
+
+from autogen import ConversableAgent
+from autogen.doc_utils import export_module
+from autogen.remote.agent_service import AgentService
+
+from .utils import request_message_from_a2a, response_message_to_a2a
+
+
+@export_module("autogen.a2a")
+class AutogenAgentExecutor(AgentExecutor):
+    """An agent executor that bridges Autogen ConversableAgents with A2A protocols.
+
+    This class wraps an Autogen ConversableAgent to enable it to be executed within
+    the A2A framework, handling message processing, task management, and event publishing.
+    """
+
+    def __init__(self, agent: ConversableAgent) -> None:
+        self.agent = AgentService(agent)
+
+    async def execute(self, context: RequestContext, event_queue: EventQueue) -> None:
+        assert context.message
+
+        task = context.current_task
+        if not task:
+            task = new_task(context.message)
+            task.status.timestamp = datetime.now(timezone.utc).isoformat()
+            # publish the task status submitted event
+            await event_queue.enqueue_event(task)
+
+        try:
+            result = await self.agent(request_message_from_a2a(context.message))
+
+        except Exception as e:
+            # publish the task status failed event
+            await event_queue.enqueue_event(
+                TaskStatusUpdateEvent(
+                    task_id=task.id,
+                    status=TaskStatus(
+                        state=TaskState.failed,
+                        message=new_agent_text_message(
+                            str(e),
+                            task_id=task.id,
+                            context_id=context.context_id,
+                        ),
+                        timestamp=datetime.now(timezone.utc).isoformat(),
+                    ),
+                    context_id=context.context_id,
+                    final=True,
+                )
+            )
+            return
+
+        artifact, messages = response_message_to_a2a(result, context.context_id, task.id)
+
+        # publish local chat history events
+        for message in messages:
+            await event_queue.enqueue_event(
+                TaskStatusUpdateEvent(
+                    task_id=task.id,
+                    status=TaskStatus(
+                        state=TaskState.working,
+                        message=message,
+                        timestamp=datetime.now(timezone.utc).isoformat(),
+                    ),
+                    context_id=context.context_id,
+                    final=False,
+                )
+            )
+
+        # publish the task result event
+        await event_queue.enqueue_event(
+            TaskArtifactUpdateEvent(
+                task_id=task.id,
+                last_chunk=True,
+                context_id=context.context_id,
+                artifact=artifact,
+            )
+        )
+
+        # publish the task status completed event
+        await event_queue.enqueue_event(
+            TaskStatusUpdateEvent(
+                task_id=task.id,
+                status=TaskStatus(
+                    state=TaskState.completed,
+                    timestamp=datetime.now(timezone.utc).isoformat(),
+                ),
+                context_id=context.context_id,
+                final=True,
+            )
+        )
+
+    async def cancel(self, context: RequestContext, event_queue: EventQueue) -> None:
+        pass