diff --git a/lib/miq_pglogical.rb b/lib/miq_pglogical.rb index 4c8115583f7..ec860d76fb0 100644 --- a/lib/miq_pglogical.rb +++ b/lib/miq_pglogical.rb @@ -41,9 +41,11 @@ def drop_node # node and creating the replication set def configure_provider return if provider? - pglogical.enable - create_node unless node? - create_replication_set + @connection.transaction(:requires_new => true) do + pglogical.enable + create_node unless node? + create_replication_set + end end # Removes the replication configuration and pglogical node from the