Skip to content

Commit 354d9be

Browse files
samuelcolvinelprans
authored andcommitted
fix for warning_callback not yet defined
1 parent f4aa9bf commit 354d9be

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

asyncpg/pool.py

+2-1
Original file line numberDiff line numberDiff line change
@@ -666,6 +666,7 @@ async def close(self):
666666

667667
self._closing = True
668668

669+
warning_callback = None
669670
try:
670671
warning_callback = self._loop.call_later(
671672
60, self._warn_on_long_close)
@@ -683,7 +684,7 @@ async def close(self):
683684
raise
684685

685686
finally:
686-
warning_callback.cancel()
687+
warning_callback and warning_callback.cancel()
687688
self._closed = True
688689
self._closing = False
689690

0 commit comments

Comments
 (0)