diff --git a/asyncpg/compat.py b/asyncpg/compat.py index b9b13fa5..7ed33bf5 100644 --- a/asyncpg/compat.py +++ b/asyncpg/compat.py @@ -58,8 +58,8 @@ async def wait_for(fut, timeout): try: return await asyncio.wait_for(fut, timeout) - except asyncio.CancelledError: - if fut.done(): + except (asyncio.CancelledError, asyncio.TimeoutError): + if fut.done() and not fut.cancelled(): return fut.result() else: raise