Code executors

.github/workflows/build.yml

@@ -42,6 +42,14 @@ jobs:
           pip install -e .
           python -c "import autogen"
           pip install pytest mock
+          pip install jupyter-client ipykernel
+          python -m ipykernel install --user --name python3
+      - name: Set AUTOGEN_USE_DOCKER based on OS
+        shell: bash
+        run: |
+          if [[ ${{ matrix.os }} != ubuntu-latest ]]; then
+            echo "AUTOGEN_USE_DOCKER=False" >> $GITHUB_ENV
+          fi
       - name: Test with pytest skipping openai tests
         if: matrix.python-version != '3.10' && matrix.os == 'ubuntu-latest'
         run: |

autogen/agentchat/agent.py

@@ -1,51 +1,61 @@
-from typing import Dict, List, Optional, Union
+from typing import Any, Callable, Dict, List, Optional, Protocol, Union, runtime_checkable
 
 
-class Agent:
-    """(In preview) An abstract class for AI agent.
+@runtime_checkable
+class Agent(Protocol):
+    """(In preview) A protocol for Agent.
 
     An agent can communicate with other agents and perform actions.
     Different agents can differ in what actions they perform in the `receive` method.
     """
 
-    def __init__(
-        self,
-        name: str,
-    ):
-        """
-        Args:
-            name (str): name of the agent.
-        """
-        # a dictionary of conversations, default value is list
-        self._name = name
-
     @property
-    def name(self):
-        """Get the name of the agent."""
-        return self._name
+    def name(self) -> str:
+        """The name of the agent."""
+        ...
 
-    def send(self, message: Union[Dict, str], recipient: "Agent", request_reply: Optional[bool] = None):
-        """(Abstract method) Send a message to another agent."""
+    @property
+    def description(self) -> str:
+        """The description of the agent. Used for the agent's introduction in
+        a group chat setting."""
+        ...
 
-    async def a_send(self, message: Union[Dict, str], recipient: "Agent", request_reply: Optional[bool] = None):
-        """(Abstract async method) Send a message to another agent."""
+    def send(
+        self,
+        message: Union[Dict[str, Any], str],
+        recipient: "Agent",
+        request_reply: Optional[bool] = None,
+    ) -> None:
+        """Send a message to another agent."""
+        ...
 
-    def receive(self, message: Union[Dict, str], sender: "Agent", request_reply: Optional[bool] = None):
-        """(Abstract method) Receive a message from another agent."""
+    async def a_send(
+        self,
+        message: Union[Dict[str, Any], str],
+        recipient: "Agent",
+        request_reply: Optional[bool] = None,
+    ) -> None:
+        """(Async) Send a message to another agent."""
+        ...
 
-    async def a_receive(self, message: Union[Dict, str], sender: "Agent", request_reply: Optional[bool] = None):
-        """(Abstract async method) Receive a message from another agent."""
+    def receive(
+        self, message: Union[Dict[str, Any], str], sender: "Agent", request_reply: Optional[bool] = None
+    ) -> None:
+        """Receive a message from another agent."""
 
-    def reset(self):
-        """(Abstract method) Reset the agent."""
+    async def a_receive(
+        self, message: Union[Dict[str, Any], str], sender: "Agent", request_reply: Optional[bool] = None
+    ) -> None:
+        """(Async) Receive a message from another agent."""
+        ...
 
     def generate_reply(
         self,
-        messages: Optional[List[Dict]] = None,
+        messages: Optional[List[Dict[str, Any]]] = None,
         sender: Optional["Agent"] = None,
-        **kwargs,
-    ) -> Union[str, Dict, None]:
-        """(Abstract method) Generate a reply based on the received messages.
+        **kwargs: Any,
+    ) -> Union[str, Dict[str, Any], None]:
+        """Generate a reply based on the received messages.
 
         Args:
             messages (list[dict]): a list of messages received.
@@ -56,15 +66,31 @@ def generate_reply(
 
     async def a_generate_reply(
         self,
-        messages: Optional[List[Dict]] = None,
+        messages: Optional[List[Dict[str, Any]]] = None,
         sender: Optional["Agent"] = None,
-        **kwargs,
-    ) -> Union[str, Dict, None]:
-        """(Abstract async method) Generate a reply based on the received messages.
+        **kwargs: Any,
+    ) -> Union[str, Dict[str, Any], None]:
+        """(Async) Generate a reply based on the received messages.
 
         Args:
             messages (list[dict]): a list of messages received.
             sender: sender of an Agent instance.
         Returns:
             str or dict or None: the generated reply. If None, no reply is generated.
         """
+
+
+@runtime_checkable
+class LLMAgent(Agent, Protocol):
+    """(In preview) A protocol for an LLM agent."""
+
+    @property
+    def system_message(self) -> str:
+        """The system message of this agent."""
+
+    def update_system_message(self, system_message: str) -> None:
+        """Update this agent's system message.
+
+        Args:
+            system_message (str): system message for inference.
+        """