feat(live): Add save_live_blob query parameter to /run_live endpoint

This change introduces a new query parameter `save_live_blob` to the `/run_live` WebSocket endpoint in the ADK web server. When set to true, this parameter enables saving of live blobs during the session. The default value is false. Unit tests are updated to cover this new parameter.

Closes issue #4707

Co-authored-by: Liang Wu <wuliang@google.com>
PiperOrigin-RevId: 901280577

Author: wuliang229

src/google/adk/cli/adk_web_server.py

@@ -2075,6 +2075,7 @@ async def run_agent_live(
         proactive_audio: bool | None = Query(default=None),
         enable_affective_dialog: bool | None = Query(default=None),
         enable_session_resumption: bool | None = Query(default=None),
+        save_live_blob: bool = Query(default=False),
     ) -> None:
       ws_origin = websocket.headers.get("origin")
       if ws_origin is not None and not _is_request_origin_allowed(
@@ -2117,6 +2118,7 @@ async def forward_events():
                 if enable_session_resumption is not None
                 else None
             ),
+            save_live_blob=save_live_blob,
         )
         async with Aclosing(
             runner.run_live(

tests/unittests/cli/test_adk_web_server_run_live.py

@@ -105,6 +105,7 @@ async def _get_runner_async(_self, _app_name: str):
       "&proactive_audio=true"
       "&enable_affective_dialog=true"
       "&enable_session_resumption=true"
+      "&save_live_blob=true"
   )
 
   with client.websocket_connect(url) as ws:
@@ -118,28 +119,32 @@ async def _get_runner_async(_self, _app_name: str):
   assert run_config.proactivity.proactive_audio is True
   assert run_config.session_resumption is not None
   assert run_config.session_resumption.transparent is True
+  assert run_config.save_live_blob is True
 
 
 @pytest.mark.parametrize(
     (
         "query,expected_enable_affective,expected_proactive_audio,"
-        "expected_session_resumption_transparent"
+        "expected_session_resumption_transparent,expected_save_live_blob"
     ),
     [
-        ("", None, None, None),
-        ("&proactive_audio=true", None, True, None),
-        ("&proactive_audio=false", None, False, None),
-        ("&enable_affective_dialog=true", True, None, None),
-        ("&enable_affective_dialog=false", False, None, None),
-        ("&enable_session_resumption=true", None, None, True),
-        ("&enable_session_resumption=false", None, None, False),
+        ("", None, None, None, False),
+        ("&proactive_audio=true", None, True, None, False),
+        ("&proactive_audio=false", None, False, None, False),
+        ("&enable_affective_dialog=true", True, None, None, False),
+        ("&enable_affective_dialog=false", False, None, None, False),
+        ("&enable_session_resumption=true", None, None, True, False),
+        ("&enable_session_resumption=false", None, None, False, False),
+        ("&save_live_blob=true", None, None, None, True),
+        ("&save_live_blob=false", None, None, None, False),
     ],
 )
 def test_run_live_defaults_and_individual_options(
     query: str,
     expected_enable_affective: bool | None,
     expected_proactive_audio: bool | None,
     expected_session_resumption_transparent: bool | None,
+    expected_save_live_blob: bool,
 ):
   session_service = InMemorySessionService()
   asyncio.run(
@@ -204,6 +209,7 @@ async def _get_runner_async(_self, _app_name: str):
         run_config.session_resumption.transparent
         is expected_session_resumption_transparent
     )
+  assert run_config.save_live_blob is expected_save_live_blob
 
 
 _WS_BASE_URL = (