scriptoriumadmin/litellm
1
0
Fork 0
mirror of https://github.com/BerriAI/litellm.git synced 2026-10-10 03:28:53 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 85

test(langfuse_otel): gate the slow sink reply instead of sleeping

Browse source 
Co-Authored-By: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com>
This commit is contained in:
yucheng 2026-09-23 12:04:15 +00:00
parent 9c1de07d9b
commit 9ca2d8e5c5
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
tests/integration/observability/test_langfuse_otel_metadata.py
View file

@ -2,7 +2,6 @@ import base64
import binascii
import json
import threading
import time
import uuid
from collections.abc import Callable, Iterator, Mapping
from concurrent.futures import ThreadPoolExecutor, wait
@ -980,8 +979,9 @@ def test_langfuse_otel_slow_sink_does_not_deadlock_exports(gateway: Gateway, tmp
marker: Final = "lf-chaos-slow-" + uuid.uuid4().hex
def sink_reply(request: Request) -> Reply:
time.sleep(2)
return Reply()
gate: Final = threading.Event()
threading.Timer(2, gate.set).start()
return Reply(chunks=(b"{}",), gate_after_first=gate)
with (
_langfuse_rig(gateway, tmp_path, {}, marker, sink_reply=sink_reply) as rig,