diff --git a/Tests/PostgresNIOTests/New/PostgresConnectionTests.swift b/Tests/PostgresNIOTests/New/PostgresConnectionTests.swift
index 28c593cb..acac9efe 100644
--- a/Tests/PostgresNIOTests/New/PostgresConnectionTests.swift
+++ b/Tests/PostgresNIOTests/New/PostgresConnectionTests.swift
@@ -964,7 +964,8 @@ import Synchronization
         do {
             try await body(connection, channel)
         } catch {
-
+            try await connection.close()
+            throw error
         }
 
         try await connection.close()