Skip to content

Commit de30043

Browse files
committed
fix: close the pools
1 parent b435ebd commit de30043

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

tests/integration/test_adapters/test_psycopg/test_connection.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ async def test_async_connection(postgres_service: PostgresService) -> None:
2626
await cur.execute("SELECT 1")
2727
result = await cur.fetchone()
2828
assert result == (1,)
29-
29+
await async_config.close_pool()
3030
# Test connection pool
3131
pool_config = PsycopgAsyncPoolConfig(
3232
conninfo=f"host={postgres_service.host} port={postgres_service.port} user={postgres_service.user} password={postgres_service.password} dbname={postgres_service.database}",
@@ -42,6 +42,7 @@ async def test_async_connection(postgres_service: PostgresService) -> None:
4242
await cur.execute("SELECT 1")
4343
result = await cur.fetchone()
4444
assert result == (1,)
45+
await another_config.close_pool()
4546

4647

4748
@pytest.mark.xdist_group("postgres")
@@ -61,7 +62,7 @@ def test_sync_connection(postgres_service: PostgresService) -> None:
6162
cur.execute("SELECT 1")
6263
result = cur.fetchone()
6364
assert result == (1,)
64-
65+
sync_config.close_pool()
6566
# Test connection pool
6667
pool_config = PsycopgSyncPoolConfig(
6768
conninfo=f"postgres://{postgres_service.user}:{postgres_service.password}@{postgres_service.host}:{postgres_service.port}/{postgres_service.database}",
@@ -77,3 +78,4 @@ def test_sync_connection(postgres_service: PostgresService) -> None:
7778
cur.execute("SELECT 1")
7879
result = cur.fetchone()
7980
assert result == (1,)
81+
another_config.close_pool()

0 commit comments

Comments
 (0)