lib/flying_sphinx/resque_delta.rb in ts-resque-delta-1.2.1 vs lib/flying_sphinx/resque_delta.rb in ts-resque-delta-1.2.2
- old
+ new
@@ -5,32 +5,29 @@
[
FlyingSphinx::ResqueDelta::DeltaJob,
FlyingSphinx::ResqueDelta::FlagAsDeletedJob
]
end
-
+
def self.job_prefix
'fs-delta'
end
-
+
def index(model, instance = nil)
return true if skip?(instance)
-
+
model.delta_index_names.each do |delta|
next if self.class.locked?(delta)
-
- Resque.enqueue(
- FlyingSphinx::ResqueDelta::DeltaJob,
- [delta]
- )
+
+ Resque.enqueue FlyingSphinx::ResqueDelta::DeltaJob, delta
end
-
+
Resque.enqueue(
FlyingSphinx::ResqueDelta::FlagAsDeletedJob,
model.core_index_names,
instance.sphinx_document_id
) if instance
-
+
true
end
end
require 'flying_sphinx/resque_delta/delta_job'