Contents

module CanvasSync::JobUniqueness
  module OnConflict
    class Reschedule < OnConflict::Base
      valid_for :perform

      def call
        Thread.current[:unique_jobs_previous_jid] = lock_context.job_id
        rescheduled = lock_context.reenqueue(
          schedule_in: schedule_in,
        )
      ensure
        Thread.current[:unique_jobs_previous_jid] = nil
      end

      def schedule_in
        lock_context.config[:reschedule_in] || 5
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
canvas_sync-0.22.0.beta2	lib/canvas_sync/job_uniqueness/on_conflict/reschedule.rb
canvas_sync-0.22.0.beta1	lib/canvas_sync/job_uniqueness/on_conflict/reschedule.rb