diff --git a/flow/connectors/postgres/validate.go b/flow/connectors/postgres/validate.go index 928fbc2d4d..ad8d45cd02 100644 --- a/flow/connectors/postgres/validate.go +++ b/flow/connectors/postgres/validate.go @@ -154,6 +154,4 @@ func (c *PostgresConnector) CheckReplicationConnectivity(ctx context.Context) er } return conn.Close(ctx) - - return nil }