Sha256: c1aeeb6c7a6fb6adeda70a0f9eec3a1b0cd116964f98f49f58cb86b5df81e22e

Contents?: true

Size: 1.19 KB

Versions: 4

Compression:

Stored size: 1.19 KB

Contents

require 'thinking_sphinx/deltas/sidekiq_delta'

namespace :thinking_sphinx do
  desc 'Lock all delta indices (Resque will not run indexer or place new jobs on the :ts_delta queue).'
  task :lock_deltas do
    ThinkingSphinx::Deltas::SidekiqDelta::CoreIndex.new.lock_deltas
  end

  desc 'Unlock all delta indices.'
  task :unlock_deltas do
    ThinkingSphinx::Deltas::SidekiqDelta::CoreIndex.new.unlock_deltas
  end

  desc 'Like `rake thinking_sphinx:index`, but locks one index at a time.'
  task :smart_index => :app_env do
    ret = ThinkingSphinx::Deltas::SidekiqDelta::CoreIndex.new.smart_index

    abort("Indexing failed.") if ret != true
  end
end

namespace :ts do
  desc 'Like `rake thinking_sphinx:index`, but locks one index at a time.'
  task :si => 'thinking_sphinx:smart_index'
end

unless Rake::Task.task_defined?('ts:index')
  require 'thinking_sphinx/tasks'
end

# Ensure that indexing does not conflict with ts-resque-delta delta jobs.
# Rake::Task['ts:index'].enhance ['thinking_sphinx:lock_deltas'] do
#   Rake::Task['thinking_sphinx:unlock_deltas'].invoke
# end

# Rake::Task['ts:reindex'].enhance ['thinking_sphinx:lock_deltas'] do
#   Rake::Task['thinking_sphinx:unlock_deltas'].invoke
# end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
ts-sidekiq-delta-0.4.0 lib/thinking_sphinx/deltas/sidekiq_delta/tasks.rb
ts-sidekiq-delta-0.3.0 lib/thinking_sphinx/deltas/sidekiq_delta/tasks.rb
ts-sidekiq-delta-0.2.0 lib/thinking_sphinx/deltas/sidekiq_delta/tasks.rb
ts-sidekiq-delta-0.1.0 lib/thinking_sphinx/deltas/sidekiq_delta/tasks.rb