# File lib/rubyrep/replication_initializer.rb, line 193 def ensure_activity_markers table_name = "#{options[:rep_prefix]}_running_flags" [:left, :right].each do |database| connection = session.send(database) unless connection.tables.include? table_name silence_ddl_notices(database) do connection.create_table table_name connection.add_column table_name, :active, :integer connection.remove_column table_name, 'id' end end end end