class RailsRedshiftReplicator::Importers::IdentityReplicator

Public Instance Methods

import() click to toggle source
# File lib/rails_redshift_replicator/importers/identity_replicator.rb, line 4
def import
  import_start = replication.importing!
  copy replication.target_table, mark_as_imported: true
  return if replication.error?
  replication.clear_errors!
  replication.update_attributes import_duration: (Time.now-import_start).ceil
  evaluate_history_cap
  file_manager.delete if RailsRedshiftReplicator.delete_s3_file_after_import
end