# 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