diff --git a/pool/pgpoolstorage/policy.go b/pool/pgpoolstorage/policy.go index 4d3e8bdbc8..89fd610f4d 100644 --- a/pool/pgpoolstorage/policy.go +++ b/pool/pgpoolstorage/policy.go @@ -34,6 +34,8 @@ func (p *PostgresPoolStorage) CheckPolicy(ctx context.Context, policy pool.Polic } else if err != nil { return false, err } + + defer rows.Close() if !rows.Next() { // should always be a row if the policy exists return false, nil }