Continue on conn closed heartbeats

inngest · Oct 15, 2024 · 8fe5f77 · 8fe5f77
1 parent 279c5cb
commit 8fe5f77
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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 {