Enhance agent streaming and logging in Analyst and Think and Prep steps

- Added consumption of text streams in both `runAnalystAgentStep` and `runThinkAndPrepAgentStep` to ensure continuous processing of agent responses.
- Introduced detailed logging at various stages of the agent's execution to improve traceability and debugging.
- These changes enhance the robustness of the agent workflow and provide better insights during execution.

packages/ai/src/steps/analyst-agent-steps/analyst-step/analyst-step.ts

@@ -26,6 +26,15 @@ export async function runAnalystAgentStep({
     const analystAgent = createAnalystAgent(options);
 
     const result = await analystAgent.stream(streamOptions);
+    
+    // Consume the text stream to ensure the agent continues processing
+    if (result.textStream) {
+      for await (const _ of result.textStream) {
+        // We don't need to do anything with the text chunks,
+        // just consume them to keep the stream flowing
+      }
+    }
+    
     const response = await result.response;
 
     if (!response || !Array.isArray(response.messages)) {

packages/ai/src/steps/analyst-agent-steps/think-and-prep-step/think-and-prep-step.ts

@@ -23,11 +23,40 @@ export async function runThinkAndPrepAgentStep({
   streamOptions,
 }: RunThinkAndPrepAgentStepInput): Promise<RunThinkAndPrepAgentStepOutput> {
   try {
+    console.info('[runThinkAndPrepAgentStep] Starting agent stream', {
+      messageId: options?.messageId,
+      messageCount: streamOptions.messages.length,
+    });
+
     const thinkAndPrepAgent = createThinkAndPrepAgent(options);
 
     const result = await thinkAndPrepAgent.stream(streamOptions);
+    
+    console.info('[runThinkAndPrepAgentStep] Stream started, consuming stream', {
+      messageId: options?.messageId,
+    });
+    
+    // Consume the text stream to ensure the agent continues processing
+    if (result.textStream) {
+      for await (const _ of result.textStream) {
+        // We don't need to do anything with the text chunks,
+        // just consume them to keep the stream flowing
+      }
+    }
+    
+    console.info('[runThinkAndPrepAgentStep] Stream consumed, awaiting response', {
+      messageId: options?.messageId,
+    });
+    
     const response = await result.response;
     
+    console.info('[runThinkAndPrepAgentStep] Response received', {
+      messageId: options?.messageId,
+      hasResponse: !!response,
+      hasMessages: !!response?.messages,
+      messageCount: response?.messages?.length,
+    });
+
     if (!response || !Array.isArray(response.messages)) {
       throw new Error(
         'Think and prep agent returned an invalid response shape (missing messages array)'