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