From 8fe5f772721c987c4adf4331196ac4aaa834952a Mon Sep 17 00:00:00 2001
From: Tony Holdstock-Brown <tonyhb@gmail.com>
Date: Tue, 15 Oct 2024 22:18:40 +0000
Subject: [PATCH] Continue on conn closed heartbeats

---
 pkg/replicator/pgreplicator/pg.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pkg/replicator/pgreplicator/pg.go b/pkg/replicator/pgreplicator/pg.go
index ce9e2cc..a0c1967 100644
--- a/pkg/replicator/pgreplicator/pg.go
+++ b/pkg/replicator/pgreplicator/pg.go
@@ -290,7 +290,7 @@ func (p *pg) Pull(ctx context.Context, cc chan *changeset.Changeset) error {
 			p.queryLock.Unlock()
 
 			if isConnClosedErr(err) && p.queryConn.IsClosed() {
-				return
+				continue
 			}
 
 			if err != nil {