diff --git a/flow/cmd/peer_data.go b/flow/cmd/peer_data.go
index 3204275fda..31ef2a2989 100644
--- a/flow/cmd/peer_data.go
+++ b/flow/cmd/peer_data.go
@@ -212,6 +212,8 @@ func (h *FlowRequestHandler) GetSlotInfo(
 	if err != nil {
 		return &protos.PeerSlotResponse{SlotData: nil}, err
 	}
+	defer pgConnector.Close()
+
 	slotInfo, err := pgConnector.GetSlotInfo("")
 	if err != nil {
 		return &protos.PeerSlotResponse{SlotData: nil}, err