diff --git a/requirements.txt b/requirements.txt
index c52a1b3d..20a2c527 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -1,7 +1,7 @@
-cloud-sql-python-connector[asyncpg]==1.17.0
+cloud-sql-python-connector[asyncpg]==1.18.1
 langchain-core==0.3.40
 numpy==2.2.3; python_version > "3.9"
 numpy== 2.0.2; python_version <= "3.9"
 pgvector==0.3.6
 SQLAlchemy[asyncio]==2.0.38
-langgraph-checkpoint==2.0.10
\ No newline at end of file
+langgraph-checkpoint==2.0.10
diff --git a/tests/test_async_checkpoint.py b/tests/test_async_checkpoint.py
index 4db1d351..cea48e6d 100644
--- a/tests/test_async_checkpoint.py
+++ b/tests/test_async_checkpoint.py
@@ -135,7 +135,6 @@ async def async_engine():
     await aexecute(async_engine, f'DROP TABLE IF EXISTS "{table_name}"')
     await aexecute(async_engine, f'DROP TABLE IF EXISTS "{table_name_writes}"')
     await async_engine.close()
-    await async_engine._connector.close_async()
 
 
 @pytest_asyncio.fixture
diff --git a/tests/test_checkpoint.py b/tests/test_checkpoint.py
index b9c6d2e6..0cd6f4ac 100644
--- a/tests/test_checkpoint.py
+++ b/tests/test_checkpoint.py
@@ -103,7 +103,6 @@ async def engine():
     await aexecute(engine, f'DROP TABLE IF EXISTS "{table_name}"')
     await aexecute(engine, f'DROP TABLE IF EXISTS "{table_name_writes}"')
     await engine.close()
-    await engine._connector.close_async()
 
 
 @pytest_asyncio.fixture
@@ -119,7 +118,6 @@ async def async_engine():
     await aexecute(async_engine, f'DROP TABLE IF EXISTS "{table_name_async}"')
     await aexecute(async_engine, f'DROP TABLE IF EXISTS "{table_name_writes_async}"')
     await async_engine.close()
-    await async_engine._connector.close_async()
 
 
 @pytest_asyncio.fixture