From 0e3dff7f2627b8e149a332a960f2119ed2436f35 Mon Sep 17 00:00:00 2001 From: Amogh Bharadwaj Date: Fri, 16 Feb 2024 00:05:58 +0530 Subject: [PATCH] Update flow/connectors/postgres/validate.go MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Philip Dubé --- flow/connectors/postgres/validate.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/postgres/validate.go b/flow/connectors/postgres/validate.go index 76b1a78a91..928fbc2d4d 100644 --- a/flow/connectors/postgres/validate.go +++ b/flow/connectors/postgres/validate.go @@ -153,7 +153,7 @@ func (c *PostgresConnector) CheckReplicationConnectivity(ctx context.Context) er return fmt.Errorf("failed to create replication connection: %v", err) } - defer conn.Close(ctx) + return conn.Close(ctx) return nil }