From a395c50084bf7a944a833379fe2e91a833711de1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Thu, 8 Feb 2024 15:30:17 +0000 Subject: [PATCH] Don't call GetSlotInfo in HandleSlotInfo, races for c.conn --- flow/connectors/postgres/postgres.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go index c2f5bf1626..7c98a8c6ea 100644 --- a/flow/connectors/postgres/postgres.go +++ b/flow/connectors/postgres/postgres.go @@ -1054,7 +1054,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