fix: handle agent-framework 1.3.0 Message contents across codebase

- shared_memory_context_provider: _get_text() now checks message.contents
- middlewares: InputObserverMiddleware handles messages with only contents (no text)
- azure_openai_response_retry: _get_message_role() handles enum roles via .value
- azure_openai_response_retry: _set_message_text() also updates contents attribute
- groupchat_orchestrator: updated comment to reference Coordinator (not manager)
- uv.lock: regenerated to match pyproject.toml pinned versions

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Author: Dhanushree-Microsoft

src/processor/src/libs/agent_framework/azure_openai_response_retry.py

@@ -228,9 +228,13 @@ def _get_message_role(message: Any) -> str | None:
         return None
     if isinstance(message, dict):
         role = message.get("role")
-        return role if isinstance(role, str) else None
+        if role is None:
+            return None
+        return role if isinstance(role, str) else getattr(role, "value", str(role))
     role = getattr(message, "role", None)
-    return role if isinstance(role, str) else None
+    if role is None:
+        return None
+    return role if isinstance(role, str) else getattr(role, "value", str(role))
 
 
 def _set_message_text(message: Any, new_text: str) -> Any:
@@ -251,13 +255,21 @@ def _set_message_text(message: Any, new_text: str) -> Any:
             out["content"] = new_text
         return out
 
-    for attr in ("content", "text"):
+    for attr in ("content", "text", "contents"):
         if hasattr(message, attr):
             try:
                 setattr(message, attr, new_text)
-                return message
             except Exception:
                 pass
+            else:
+                if attr != "contents":
+                    # Also update contents if it exists for agent-framework 1.3.0 compat
+                    if hasattr(message, "contents"):
+                        try:
+                            setattr(message, "contents", new_text)
+                        except Exception:
+                            pass
+                return message
     return message
 
 

src/processor/src/libs/agent_framework/groupchat_orchestrator.py

@@ -989,7 +989,7 @@ async def _complete_agent_response(
         if agent_name != self.coordinator_name:
             self._progress_counter += 1
 
-        # Detect manager termination signal (finish=true) from Coordinator.
+        # Detect Coordinator termination signal (finish=true) via CoordinatorSelectionResponse.
         # NOTE: The underlying WorkflowBuilder does not automatically stop on finish,
         # so we enforce it here.
         if agent_name == self.coordinator_name:

src/processor/src/libs/agent_framework/middlewares.py

@@ -149,8 +149,10 @@ async def process(
         modified_count = 0
 
         for message in context.messages:
-            if message.role == ROLE_USER and message.text:
-                original_text = message.text
+            original_text = message.text if message.text else (
+                str(message.contents) if hasattr(message, "contents") and message.contents else None
+            )
+            if message.role == ROLE_USER and original_text:
                 updated_text = original_text
 
                 if self.replacement:

src/processor/src/libs/agent_framework/shared_memory_context_provider.py

@@ -307,6 +307,8 @@ def _get_text(message: Message) -> str:
         """Extract text content from a Message."""
         if hasattr(message, "text") and message.text:
             return message.text
+        if hasattr(message, "contents") and message.contents:
+            return str(message.contents) if not isinstance(message.contents, str) else message.contents
         if hasattr(message, "content"):
             return str(message.content) if message.content else ""
         return str(message) if message else ""