From: Daniele Varrazzo <daniele.varrazzo@gmail.com>
Date: Fri, 16 Apr 2021 11:37:42 +0000 (+0100)
Subject: Fix missing dsn in async pool tests too
X-Git-Tag: 3.0.dev0~69
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=bbaada6458b1ebb3c09c81420e6ddf37be939652;p=thirdparty%2Fpsycopg.git

Fix missing dsn in async pool tests too
---

diff --git a/tests/pool/test_pool_async.py b/tests/pool/test_pool_async.py
index 230b716f2..fb2e5aeba 100644
--- a/tests/pool/test_pool_async.py
+++ b/tests/pool/test_pool_async.py
@@ -162,7 +162,9 @@ async def test_configure(dsn):
         async with conn.transaction():
             await conn.execute("set default_transaction_read_only to on")
 
-    async with pool.AsyncConnectionPool(min_size=1, configure=configure) as p:
+    async with pool.AsyncConnectionPool(
+        dsn, min_size=1, configure=configure
+    ) as p:
         await p.wait(timeout=1.0)
         async with p.connection() as conn:
             assert inits == 1
@@ -188,7 +190,9 @@ async def test_configure_badstate(dsn, caplog):
     async def configure(conn):
         await conn.execute("select 1")
 
-    async with pool.AsyncConnectionPool(min_size=1, configure=configure) as p:
+    async with pool.AsyncConnectionPool(
+        dsn, min_size=1, configure=configure
+    ) as p:
         with pytest.raises(pool.PoolTimeout):
             await p.wait(timeout=0.5)
 
@@ -204,7 +208,9 @@ async def test_configure_broken(dsn, caplog):
         async with conn.transaction():
             await conn.execute("WAT")
 
-    async with pool.AsyncConnectionPool(min_size=1, configure=configure) as p:
+    async with pool.AsyncConnectionPool(
+        dsn, min_size=1, configure=configure
+    ) as p:
         with pytest.raises(pool.PoolTimeout):
             await p.wait(timeout=0.5)
 
@@ -225,7 +231,7 @@ async def test_reset(dsn):
         async with conn.transaction():
             await conn.execute("set timezone to utc")
 
-    async with pool.AsyncConnectionPool(min_size=1, reset=reset) as p:
+    async with pool.AsyncConnectionPool(dsn, min_size=1, reset=reset) as p:
         async with p.connection() as conn:
             assert resets == 0
             await conn.execute("set timezone to '+2:00'")
@@ -247,7 +253,7 @@ async def test_reset_badstate(dsn, caplog):
     async def reset(conn):
         await conn.execute("reset all")
 
-    async with pool.AsyncConnectionPool(min_size=1, reset=reset) as p:
+    async with pool.AsyncConnectionPool(dsn, min_size=1, reset=reset) as p:
         async with p.connection() as conn:
             await conn.execute("select 1")
             pid1 = conn.pgconn.backend_pid
@@ -268,7 +274,7 @@ async def test_reset_broken(dsn, caplog):
         async with conn.transaction():
             await conn.execute("WAT")
 
-    async with pool.AsyncConnectionPool(min_size=1, reset=reset) as p:
+    async with pool.AsyncConnectionPool(dsn, min_size=1, reset=reset) as p:
         async with p.connection() as conn:
             await conn.execute("select 1")
             pid1 = conn.pgconn.backend_pid