diff --git a/module/ldbc-connector/shared/src/main/scala/ldbc/connector/pool/PooledDataSource.scala b/module/ldbc-connector/shared/src/main/scala/ldbc/connector/pool/PooledDataSource.scala
index ae33e225a..c98c8ef99 100644
--- a/module/ldbc-connector/shared/src/main/scala/ldbc/connector/pool/PooledDataSource.scala
+++ b/module/ldbc-connector/shared/src/main/scala/ldbc/connector/pool/PooledDataSource.scala
@@ -238,7 +238,8 @@ object PooledDataSource:
           val closeAll = state.connections.traverse_ { pooled =>
             pooled.finalizer.attempt.flatMap {
               case Left(error) =>
-                poolLogger.debug(s"Error closing connection ${ pooled.id }: ${ error.getMessage }")
+                poolLogger.debug(s"Error closing connection ${ pooled.id }: ${ error.getMessage }") >>
+                  pooled.connection.close().attempt.void
               case Right(_) =>
                 Temporal[F].unit
             }