From 806e827a41839a4d5a4462e546da97235b46aeab Mon Sep 17 00:00:00 2001 From: Anthony Shaw Date: Tue, 14 Oct 2025 10:41:04 +1100 Subject: [PATCH 1/3] Handle dict input for MagenticStartMessage --- python/packages/core/agent_framework/_workflows/_magentic.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/python/packages/core/agent_framework/_workflows/_magentic.py b/python/packages/core/agent_framework/_workflows/_magentic.py index 3ee1c1069..4ee790074 100644 --- a/python/packages/core/agent_framework/_workflows/_magentic.py +++ b/python/packages/core/agent_framework/_workflows/_magentic.py @@ -2087,7 +2087,8 @@ async def run_stream(self, message: Any | None = None) -> AsyncIterable[Workflow message = MagenticStartMessage.from_string(message) elif isinstance(message, ChatMessage): message = MagenticStartMessage(task=message) - + elif isinstance(message, dict) and 'input' in message: + message = MagenticStartMessage(task=message['input']) async for event in self._workflow.run_stream(message): yield event From 3fa03f54157eeecb871df1b71afed3ca7a1703b9 Mon Sep 17 00:00:00 2001 From: Anthony Shaw Date: Tue, 14 Oct 2025 10:47:09 +1100 Subject: [PATCH 2/3] Use correct API --- python/packages/core/agent_framework/_workflows/_magentic.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/python/packages/core/agent_framework/_workflows/_magentic.py b/python/packages/core/agent_framework/_workflows/_magentic.py index 4ee790074..5f519dbc9 100644 --- a/python/packages/core/agent_framework/_workflows/_magentic.py +++ b/python/packages/core/agent_framework/_workflows/_magentic.py @@ -2088,7 +2088,8 @@ async def run_stream(self, message: Any | None = None) -> AsyncIterable[Workflow elif isinstance(message, ChatMessage): message = MagenticStartMessage(task=message) elif isinstance(message, dict) and 'input' in message: - message = MagenticStartMessage(task=message['input']) + message = MagenticStartMessage.from_string(message['input']) + async for event in self._workflow.run_stream(message): yield event From fbbd33eb1d4a11efc80177f4b4d66d26c3b7f79a Mon Sep 17 00:00:00 2001 From: Anthony Shaw Date: Tue, 14 Oct 2025 11:08:27 +1100 Subject: [PATCH 3/3] Fix string quotes in message handling logic --- python/packages/core/agent_framework/_workflows/_magentic.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/python/packages/core/agent_framework/_workflows/_magentic.py b/python/packages/core/agent_framework/_workflows/_magentic.py index 5f519dbc9..c2628a259 100644 --- a/python/packages/core/agent_framework/_workflows/_magentic.py +++ b/python/packages/core/agent_framework/_workflows/_magentic.py @@ -2087,8 +2087,8 @@ async def run_stream(self, message: Any | None = None) -> AsyncIterable[Workflow message = MagenticStartMessage.from_string(message) elif isinstance(message, ChatMessage): message = MagenticStartMessage(task=message) - elif isinstance(message, dict) and 'input' in message: - message = MagenticStartMessage.from_string(message['input']) + elif isinstance(message, dict) and "input" in message: + message = MagenticStartMessage.from_string(message["input"]) async for event in self._workflow.run_stream(message): yield event