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] || 60
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
canvas_sync-0.22.0.beta7	lib/canvas_sync/job_uniqueness/on_conflict/reschedule.rb
canvas_sync-0.22.0.beta6	lib/canvas_sync/job_uniqueness/on_conflict/reschedule.rb
canvas_sync-0.22.0.beta5	lib/canvas_sync/job_uniqueness/on_conflict/reschedule.rb
canvas_sync-0.22.0.beta4	lib/canvas_sync/job_uniqueness/on_conflict/reschedule.rb
canvas_sync-0.22.0.beta3	lib/canvas_sync/job_uniqueness/on_conflict/reschedule.rb