Update flow/connectors/postgres/validate.go

Co-authored-by: Philip Dubé <[email protected]>
PeerDB-io · Feb 15, 2024 · 0e3dff7 · 0e3dff7
1 parent 151b29d
commit 0e3dff7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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
 }