Contents

module CanvasSync
  module Jobs
    class TermBatchesJob < CanvasSync::Job
      def perform(options)
        if (jobs = options[:sub_jobs]).present?
          context = options[:context] || {}
          if options[:term_scope]
            Term.send(options[:term_scope]).find_each.map do |term|
              term_id = get_term_id(term)
              local_context = context.merge(canvas_term_id: term_id)

              # Override the delta-syncing date if:
              # 1. the Term hasn't been synced before or
              # 2. the Term underwent a period of not syncing
              term_last_sync = CanvasSync.redis.get(self.class.last_sync_key(term_id))
              if batch_context[:updated_after]
                if !term_last_sync.present? || batch_context[:updated_after] > term_last_sync
                  local_context[:updated_after] = term_last_sync.presence
                end
              end

              JobBatches::ManagedBatchJob.make_batch(jobs, ordered: false, concurrency: true) do |b|
                b.description = "TermBatchJob(#{term.canvas_id}) Root"
                b.context = local_context
                b.on(:success, "#{self.class.to_s}.batch_finished")
              end
            end
          else
            JobBatches::ConcurrentBatchJob.make_batch(jobs, context: context)
          end
        end
      end

      def self.batch_finished(status, opts)
        ctx = JobBatches::Batch.current_context
        term_id = ctx[:canvas_term_id]
        CanvasSync.redis.set(last_sync_key(term_id), ctx[:batch_start_time])
      end

      def self.last_sync_key(term_id)
        ctx = JobBatches::Batch.current_context
        "#{CanvasSync.redis_prefix}:#{ctx[:batch_genre]}:#{term_id}:last_sync"
      end

      def get_term_id(term)
        term.try(:canvas_id) || term.canvas_term_id
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
canvas_sync-0.17.28	lib/canvas_sync/jobs/term_batches_job.rb
canvas_sync-0.17.27	lib/canvas_sync/jobs/term_batches_job.rb