From ca5e3106c4a8a871a4b794306c1215fa5cecfca4 Mon Sep 17 00:00:00 2001
From: goran-revops <46086727+goran-revops@users.noreply.github.com>
Date: Thu, 24 Sep 2026 13:23:42 +0200
Subject: [PATCH] Test that the SSE keepalive task shares the parallel-request
 slot.

---
 .../proxy/test_sse_keepalive_request_stash.py | 34 +++++++++++++++++++
 1 file changed, 34 insertions(+)
 create mode 100644 tests/test_litellm/proxy/test_sse_keepalive_request_stash.py

diff --git a/tests/test_litellm/proxy/test_sse_keepalive_request_stash.py b/tests/test_litellm/proxy/test_sse_keepalive_request_stash.py
new file mode 100644
index 00000000000..d7c582d1ebe
--- /dev/null
+++ b/tests/test_litellm/proxy/test_sse_keepalive_request_stash.py
@@ -0,0 +1,34 @@
+"""The SSE keepalive task must share the parallel-request slot with its caller."""
+
+import asyncio
+
+from litellm.proxy.hooks.parallel_request_limiter_v3 import (
+    _request_stash,
+    get_or_create_request_stash,
+    get_request_stash,
+)
+
+
+def test_sse_keepalive_fork_shares_the_parallel_request_slot():
+    async def process():
+        get_or_create_request_stash().owner_litellm_call_id = "call-1"
+
+    async def without_seed():
+        _request_stash.set(None)
+        task = asyncio.ensure_future(process())
+        await asyncio.wait((task,))
+        return get_request_stash()
+
+    async def with_seed():
+        _request_stash.set(None)
+        get_or_create_request_stash()
+        task = asyncio.ensure_future(process())
+        await asyncio.wait((task,))
+        return get_request_stash()
+
+    leaked = asyncio.run(without_seed())
+    shared = asyncio.run(with_seed())
+
+    assert leaked is None
+    assert shared is not None
+    assert shared.owner_litellm_call_id == "call-1"