Skip to content

Commit aa0aa39

Browse files
committed
Fix engine compatibility
1 parent 308c5a5 commit aa0aa39

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

psqlpy_piccolo/engine.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -547,6 +547,9 @@ async def close_connection_pool(self) -> None:
547547

548548
async def get_new_connection(self) -> Connection:
549549
"""Returns a new connection - doesn't retrieve it from the pool."""
550+
if self.pool:
551+
return await self.pool.connection()
552+
550553
config = dict(self.config)
551554
return await (
552555
ConnectionPool(

0 commit comments

Comments
 (0)