fix: use local_timeout_duration in async timeout wrapper

This commit is contained in:
7. Sun 2026-03-23 13:20:06 +00:00
parent c89496f378
commit d85c671a87

View file

@ -71,7 +71,7 @@ def timeout(timeout_duration: float = 0.0, exception_to_raise=Timeout):
local_timeout_duration = kwargs["request_timeout"]
try:
value = await asyncio.wait_for(
func(*args, **kwargs), timeout=timeout_duration
func(*args, **kwargs), timeout=local_timeout_duration
)
return value
except asyncio.TimeoutError: