def handle_delete_propagation
      if replicable.tracking_deleted && has_deleted_ids?
        RailsRedshiftReplicator.logger.info propagation_message(:propagating_deletes)
        delete_on_target ? purge_deleted : RailsRedshiftReplicator.logger.error(propagation_message(:delete_propagation_error))
      end
    end
def handle_delete_propagation
      if replicable.tracking_deleted && has_deleted_ids?
        RailsRedshiftReplicator.logger.info propagation_message(:propagating_deletes)
        delete_on_target ? purge_deleted : RailsRedshiftReplicator.logger.error(propagation_message(:delete_propagation_error))
      end
    end
def handle_delete_propagation if replicable . tracking_deleted && has_deleted_ids? RailsRedshiftReplicator . logger . info propagation_message ( :propagating_deletes ) delete_on_target ? purge_deleted : RailsRedshiftReplicator . logger . error ( propagation_message ( :delete_propagation_error ) ) end end
Deletes records flagged for deletion on target and then delete the queue from source
Deletes records flagged for deletion on target and then delete the queue from source