fix: use correct Message attributes in _validate_sign_offs (text/author_name)

_validate_sign_offs was using msg.content and msg.source which do not
exist on agent-framework 1.3.0 Message objects, causing runtime crashes.
Updated to use msg.text and msg.author_name. Updated corresponding test
mocks to use the new API attributes.

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

Author: Prachig-Microsoft

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

@@ -398,8 +398,8 @@ def _validate_sign_offs(self, conversation: list[Message]) -> tuple[bool, str]:
 
         # Search for sign-off patterns in messages
         for msg in recent_messages:
-            content = str(msg.content).upper()
-            agent_name = msg.source if hasattr(msg, "source") else None
+            content = (msg.text or str(msg.contents)).upper()
+            agent_name = getattr(msg, "author_name", None) or getattr(msg, "source", None)
 
             if not agent_name or agent_name == self.coordinator_name:
                 continue

src/processor/src/tests/unit/libs/agent_framework/test_groupchat_orchestrator_internals.py

@@ -219,38 +219,38 @@ class TestValidateSignOffs:
     def test_all_pass(self):
         orch = _make_orch()
         msgs = [
-            _Msg(source="A", content="SIGN-OFF: PASS"),
-            _Msg(source="B", content="SIGN-OFF:PASS"),
+            _Msg(author_name="A", text="SIGN-OFF: PASS"),
+            _Msg(author_name="B", text="SIGN-OFF:PASS"),
         ]
         ok, reason = orch._validate_sign_offs(msgs)
         assert ok is True
 
     def test_pending_blocks(self):
         orch = _make_orch()
-        msgs = [_Msg(source="A", content="SIGN-OFF: PENDING")]
+        msgs = [_Msg(author_name="A", text="SIGN-OFF: PENDING")]
         ok, reason = orch._validate_sign_offs(msgs)
         assert ok is False
         assert "PENDING" in reason
 
     def test_fail_blocks(self):
         orch = _make_orch()
-        msgs = [_Msg(source="A", content="SIGN-OFF: FAIL")]
+        msgs = [_Msg(author_name="A", text="SIGN-OFF: FAIL")]
         ok, reason = orch._validate_sign_offs(msgs)
         assert ok is False
         assert "FAIL" in reason
 
     def test_missing_blocks(self):
         orch = _make_orch()
-        msgs = [_Msg(source="A", content="some text without signoff")]
+        msgs = [_Msg(author_name="A", text="some text without signoff")]
         ok, reason = orch._validate_sign_offs(msgs)
         assert ok is False
         assert "missing" in reason
 
     def test_excludes_coordinator_and_resultgenerator(self):
         orch = _make_orch()
         msgs = [
-            _Msg(source="Coordinator", content="ignored"),
-            _Msg(source="ResultGenerator", content="ignored"),
+            _Msg(author_name="Coordinator", text="ignored"),
+            _Msg(author_name="ResultGenerator", text="ignored"),
         ]
         ok, _ = orch._validate_sign_offs(msgs)
         assert ok is True

src/processor/src/tests/unit/libs/agent_framework/test_groupchat_orchestrator_termination.py

@@ -13,8 +13,10 @@
 
 @dataclass
 class _Msg:
-    source: str
-    content: str
+    author_name: str = ""
+    text: str = ""
+    contents: object = None
+    role: object = None
 
 
 def _make_orchestrator() -> GroupChatOrchestrator:
@@ -34,8 +36,8 @@ async def _run():
 
         # Everyone who participated signed off PASS.
         orch._conversation = [
-            _Msg(source="AKS Expert", content="SIGN-OFF: PASS"),
-            _Msg(source="Chief Architect", content="SIGN-OFF: PASS"),
+            _Msg(author_name="AKS Expert", text="SIGN-OFF: PASS"),
+            _Msg(author_name="Chief Architect", text="SIGN-OFF: PASS"),
         ]
 
         orch._current_agent_start_time = datetime.now()
@@ -65,7 +67,7 @@ async def _run():
 
         # Agent participated but never produced a SIGN-OFF.
         orch._conversation = [
-            _Msg(source="AKS Expert", content="Reviewed; looks good."),
+            _Msg(author_name="AKS Expert", text="Reviewed; looks good."),
         ]
 
         orch._current_agent_start_time = datetime.now()