diff --git a/python/packages/core/agent_framework/_workflows/_magentic.py b/python/packages/core/agent_framework/_workflows/_magentic.py
index 3ee1c1069..c2628a259 100644
--- a/python/packages/core/agent_framework/_workflows/_magentic.py
+++ b/python/packages/core/agent_framework/_workflows/_magentic.py
@@ -2087,6 +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"])
 
         async for event in self._workflow.run_stream(message):
             yield event