INNER CODE UNIT · Python

handle_message

victordibia/designing-multiagent-systems · course/samples/hello_world/autogen_core/app.py:69

    async def handle_message(self, message: Message, ctx: MessageContext) -> Optional[Message]:
        # Check for termination conditions
        if "TERMINATE" in message.content:
            return None

        if self._max_messages and self._message_count >= self._max_messages:
            return None

        self._message_count += 1

        # Create a session of messages
        session = [UserMessage(content=message.content, source="user")]

        # Run the tool caller loop to handle calculations
        messages = await tool_agent_caller_loop(
            self,
            tool_agent_id=self._tool_agent_id,
            model_client=self._model_client,

View source record →