fix: Workflow.run_stream() -> run(stream=True) in 1.1.1

Workflow no longer has run_stream() method. Use run(message, stream=True)
instead, which returns an async iterator of WorkflowEvents.

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

Author: Prachig-Microsoft

src/ContentProcessorWorkflow/src/libs/agent_framework/groupchat_orchestrator.py

@@ -628,7 +628,7 @@ async def run_stream(
             # Execute with streaming
             conversation: list[Message] = []
 
-            async for event in group_chat_workflow.run_stream(task_prompt):
+            async for event in group_chat_workflow.run(task_prompt, stream=True):
                 # Enforce wall-clock timeout if configured.
                 if self.max_seconds is not None:
                     elapsed = (datetime.now() - start_time).total_seconds()

src/ContentProcessorWorkflow/src/steps/claim_processor.py

@@ -215,7 +215,7 @@ async def run(self, input_data: str) -> Any:
         last_invoked_executor_id: str | None = None
 
         try:
-            async for event in self.workflow.run_stream(input_data):
+            async for event in self.workflow.run(input_data, stream=True):
                 event: WorkflowEvent
                 if event.type == "started":
                     logger.info("Workflow started (%s)", event.origin.value)