diff --git a/shard.yml b/shard.yml
index 83055c8..7bebe6b 100644
--- a/shard.yml
+++ b/shard.yml
@@ -23,8 +23,8 @@ dependencies:
     github: anykeyh/generate.cr
     branch: master
   pg:
-    github: will/crystal-pg
-    version: 0.23.2
+    github: place-labs/crystal-pg
+    version: master
   inflector:
     github: anykeyh/inflector.cr
     branch: master
diff --git a/src/clear/sql/connection_pool.cr b/src/clear/sql/connection_pool.cr
index 50b24d9..01b4652 100644
--- a/src/clear/sql/connection_pool.cr
+++ b/src/clear/sql/connection_pool.cr
@@ -14,10 +14,9 @@ class Clear::SQL::ConnectionPool
     fiber_target = {target, Fiber.current}
 
     database = @@databases.fetch(target) { raise Clear::ErrorMessages.uninitialized_db_connection(target) }
-
     cnx = @@fiber_connections[fiber_target]?
 
-    if cnx
+    if cnx && !cnx.closed?
       yield cnx
     else
       database.using_connection do |new_connection|