diff --git a/tests/test_gateway_sse_reconnect_dedupe.py b/tests/test_gateway_sse_reconnect_dedupe.py
index 11afbfe9..4001a965 100644
--- a/tests/test_gateway_sse_reconnect_dedupe.py
+++ b/tests/test_gateway_sse_reconnect_dedupe.py
@@ -129,7 +129,7 @@ if(!_isDuplicateGatewaySessionSnapshot([null, {session_id:'web-2', session_sourc
 def test_load_session_persists_only_after_metadata_loads():
     """Do not overwrite the last good localStorage sid before /api/session succeeds."""
     src = _read(SESSIONS_JS)
-    load = _block(src, "async function loadSession(sid)", "activeStreamId=S.session.active_stream_id")
+    load = _block(src, "async function loadSession(sid)", "function _mergePendingSessionMessage")
     api_pos = load.index("data = await api(`/api/session")
     persist_pos = load.index("localStorage.setItem('hermes-webui-session',S.session.session_id)")
 
diff --git a/tests/test_stale_stream_cleanup.py b/tests/test_stale_stream_cleanup.py
index 2fe67c65..2bd34e40 100644
--- a/tests/test_stale_stream_cleanup.py
+++ b/tests/test_stale_stream_cleanup.py
@@ -435,7 +435,7 @@ def test_frontend_drops_inflight_cache_when_server_session_is_idle():
     # (preserved) cache-drop behavior in the now-nested form.
     marker = "If the server says the session is idle, reset browser-side streaming flags"
     marker_pos = SESSIONS_SRC.index(marker)
-    window = SESSIONS_SRC[marker_pos:marker_pos + 900]
+    window = SESSIONS_SRC[marker_pos:marker_pos + 1400]
     assert "if(!activeStreamId){" in window
     assert "S.busy=false" in window
     assert "S.activeStreamId=null" in window