pg HandleSlotInfo: don't use c.conn for getSlotInfo (#1229)

This raced with PullRecords
PeerDB-io · Feb 8, 2024 · 74264f2 · 74264f2
1 parent 08b8cf9
commit 74264f2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go
@@ -922,7 +922,7 @@ func (c *PostgresConnector) HandleSlotInfo(
 	}
 	defer conn.Close(ctx)
 
-	slotInfo, err := c.GetSlotInfo(slotName)
+	slotInfo, err := getSlotInfo(ctx, conn, slotName, c.config.Database)
 	if err != nil {
 		slog.WarnContext(ctx, "warning: failed to get slot info", slog.Any("error", err))
 		return err