feat: Updates the ADK template to direct structured JSON logs to standard output.

PiperOrigin-RevId: 837124358

Author: vertex-sdk-bot

vertexai/agent_engines/templates/adk.py

@@ -27,6 +27,7 @@
 import asyncio
 from collections.abc import Awaitable
 import queue
+import sys
 import threading
 import warnings
 
@@ -439,12 +440,13 @@ def _detect_cloud_resource_id(project_id: str) -> Optional[str]:
 
         logger_provider = opentelemetry.sdk._logs.LoggerProvider(resource=resource)
         logger_provider.add_log_record_processor(
-            opentelemetry.sdk._logs.export.BatchLogRecordProcessor(
+            opentelemetry.sdk._logs.export.SimpleLogRecordProcessor(
                 opentelemetry.exporter.cloud_logging.CloudLoggingExporter(
                     project_id=project_id,
                     default_log_name=os.getenv(
                         "GCP_DEFAULT_LOG_NAME", "adk-on-agent-engine"
                     ),
+                    structured_json_file=sys.stdout,
                 ),
             )
         )

vertexai/preview/reasoning_engines/templates/adk.py

@@ -27,6 +27,7 @@
 import asyncio
 from collections.abc import Awaitable
 import queue
+import sys
 import threading
 
 
@@ -441,12 +442,13 @@ def _detect_cloud_resource_id(project_id: str) -> Optional[str]:
 
         logger_provider = opentelemetry.sdk._logs.LoggerProvider(resource=resource)
         logger_provider.add_log_record_processor(
-            opentelemetry.sdk._logs.export.BatchLogRecordProcessor(
+            opentelemetry.sdk._logs.export.SimpleLogRecordProcessor(
                 opentelemetry.exporter.cloud_logging.CloudLoggingExporter(
                     project_id=project_id,
                     default_log_name=os.getenv(
                         "GCP_DEFAULT_LOG_NAME", "adk-on-agent-engine"
                     ),
+                    structured_json_file=sys.stdout,
                 ),
             )
         )