class CanvasSync::JobBatches::Batch

def redis(&blk)
  return RedisProxy.new unless block_given?
  if Thread.current[:job_batches_redis]
    yield Thread.current[:job_batches_redis]
  elsif defined?(::Sidekiq)
    ::Sidekiq.redis do |r|
      Thread.current[:job_batches_redis] = r
      yield r
    ensure
      Thread.current[:job_batches_redis] = nil
    end
  else
    # TODO
  end
end