fix typo

cybertec-postgresql · Nov 15, 2023 · b55af11 · b55af11
1 parent 3c4d54a
commit b55af11
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/pgengine/bootstrap.go b/internal/pgengine/bootstrap.go
@@ -187,7 +187,7 @@ func (pge *PgEngine) getPgxConnConfig() *pgxpool.Config {
 		if pgconn.DeallocateAll(context.Background()) != nil {
 			return false // destroy the connection in case of error
 		}
-		_, err = pgconn.Exec(context.Background(), "DISCARD ALL")
+		if _, err = pgconn.Exec(context.Background(), "DISCARD ALL"); err == nil {
 			_, err = pgconn.Exec(context.Background(), "LISTEN "+quoteIdent(pge.ClientName))
 		}
 		return err == nil