debug: add print diagnostics to stream_lifecycle_content activity

Author: prassanna-ravishankar

src/agentex/lib/core/temporal/plugins/openai_agents/hooks/activities.py

@@ -61,10 +61,12 @@ async def stream_lifecycle_content(
         that streaming failures don't break the agent execution.
     """
     try:
+        print(f"[stream_lifecycle_content] Creating message for task {task_id}, content_type={getattr(content, 'type', 'unknown')}", flush=True)
         async with adk.streaming.streaming_task_message_context(
             task_id=task_id,
             initial_content=content,
         ) as streaming_context:
+            print(f"[stream_lifecycle_content] Context opened, message_id={streaming_context.task_message.id if streaming_context.task_message else 'None'}", flush=True)
             # Send the content as a full message update
             await streaming_context.stream_update(
                 StreamTaskMessageFull(
@@ -73,6 +75,8 @@ async def stream_lifecycle_content(
                     type="full",
                 )
             )
+            print(f"[stream_lifecycle_content] Full update sent for content_type={getattr(content, 'type', 'unknown')}", flush=True)
     except Exception as e:
         # Log error but don't fail the activity - streaming failures shouldn't break execution
+        print(f"[stream_lifecycle_content] FAILED for task {task_id}: {e}", flush=True)
         activity.logger.warning(f"Failed to stream content to task {task_id}: {e}")