Module: SpatialFeatures::QueuedSpatialProcessing
- Extended by:
- ActiveSupport::Concern
- Included in:
- FeatureImport
- Defined in:
- lib/spatial_features/has_spatial_features/queued_spatial_processing.rb
Instance Method Summary collapse
- #delay_update_features!(*args) ⇒ Object
- #failed_feature_update_jobs ⇒ Object
- #feature_update_error ⇒ Object
- #queue_update_spatial_cache(*args) ⇒ Object
- #running_feature_update_jobs ⇒ Object
- #spatial_processing_jobs(suffix = nil) ⇒ Object
- #updating_features? ⇒ Boolean
Instance Method Details
#delay_update_features!(*args) ⇒ Object
9 10 11 |
# File 'lib/spatial_features/has_spatial_features/queued_spatial_processing.rb', line 9 def delay_update_features!(*args) queue_spatial_task('update_features!', *args) end |
#failed_feature_update_jobs ⇒ Object
25 26 27 |
# File 'lib/spatial_features/has_spatial_features/queued_spatial_processing.rb', line 25 def failed_feature_update_jobs spatial_processing_jobs('update_features!').where.not(failed_at: nil) end |
#feature_update_error ⇒ Object
17 18 19 |
# File 'lib/spatial_features/has_spatial_features/queued_spatial_processing.rb', line 17 def feature_update_error (failed_feature_update_jobs.first.try(:last_error) || '').split("\n").first end |
#queue_update_spatial_cache(*args) ⇒ Object
5 6 7 |
# File 'lib/spatial_features/has_spatial_features/queued_spatial_processing.rb', line 5 def queue_update_spatial_cache(*args) queue_spatial_task('update_spatial_cache', *args) end |
#running_feature_update_jobs ⇒ Object
21 22 23 |
# File 'lib/spatial_features/has_spatial_features/queued_spatial_processing.rb', line 21 def running_feature_update_jobs spatial_processing_jobs('update_features!').where(failed_at: nil) end |
#spatial_processing_jobs(suffix = nil) ⇒ Object
29 30 31 |
# File 'lib/spatial_features/has_spatial_features/queued_spatial_processing.rb', line 29 def spatial_processing_jobs(suffix = nil) Delayed::Job.where('queue LIKE ?', "#{spatial_processing_queue_name}#{suffix}%") end |
#updating_features? ⇒ Boolean
13 14 15 |
# File 'lib/spatial_features/has_spatial_features/queued_spatial_processing.rb', line 13 def updating_features? running_feature_update_jobs.exists? end |