aboutsummaryrefslogtreecommitdiff
path: root/lib/chewy/strategy/custom_sidekiq.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/chewy/strategy/custom_sidekiq.rb')
-rw-r--r--lib/chewy/strategy/custom_sidekiq.rb25
1 files changed, 3 insertions, 22 deletions
diff --git a/lib/chewy/strategy/custom_sidekiq.rb b/lib/chewy/strategy/custom_sidekiq.rb
index 3e54326ba..794ae4ed4 100644
--- a/lib/chewy/strategy/custom_sidekiq.rb
+++ b/lib/chewy/strategy/custom_sidekiq.rb
@@ -2,29 +2,10 @@
module Chewy
class Strategy
- class CustomSidekiq < Base
- class Worker
- include ::Sidekiq::Worker
-
- sidekiq_options queue: 'pull'
-
- def perform(type, ids, options = {})
- options[:refresh] = !Chewy.disable_refresh_async if Chewy.disable_refresh_async
- type.constantize.import!(ids, options)
- end
- end
-
- def update(type, objects, _options = {})
- return unless Chewy.enabled?
-
- ids = type.root.id ? Array.wrap(objects) : type.adapter.identify(objects)
-
- return if ids.empty?
-
- Worker.perform_async(type.name, ids)
+ class CustomSidekiq < Sidekiq
+ def update(_type, _objects, _options = {})
+ super if Chewy.enabled?
end
-
- def leave; end
end
end
end