Module: SpatialFeatures::DelayedFeatureImport

Extended by:
ActiveSupport::Concern
Includes:
FeatureImport
Defined in:
lib/spatial_features/has_spatial_features/delayed_feature_import.rb

Instance Method Summary collapse

Methods included from FeatureImport

#update_features!

Instance Method Details

#failed_feature_update_jobs ⇒ Object 



23
24
25
 
# File 'lib/spatial_features/has_spatial_features/delayed_feature_import.rb', line 23

def failed_feature_update_jobs
  feature_update_jobs.where.not(failed_at: nil)
end

#feature_update_error ⇒ Object 



15
16
17
 
# File 'lib/spatial_features/has_spatial_features/delayed_feature_import.rb', line 15

def feature_update_error
  (failed_feature_update_jobs.first.try(:last_error) || '').split("\n").first
end

#feature_update_jobs ⇒ Object 



27
28
29
 
# File 'lib/spatial_features/has_spatial_features/delayed_feature_import.rb', line 27

def feature_update_jobs
  Delayed::Job.where(queue: delayed_jobs_queue_name)
end

#queue_feature_update!(options = {}) ⇒ Object 



6
7
8
9
 
# File 'lib/spatial_features/has_spatial_features/delayed_feature_import.rb', line 6

def queue_feature_update!(options = {})
  job = UpdateFeaturesJob.new(options.merge :spatial_model_type => self.class, :spatial_model_id => self.id)
  Delayed::Job.enqueue(job, :queue => delayed_jobs_queue_name)
end

#running_feature_update_jobs ⇒ Object 



19
20
21
 
# File 'lib/spatial_features/has_spatial_features/delayed_feature_import.rb', line 19

def running_feature_update_jobs
  feature_update_jobs.where(failed_at: nil)
end

#updating_features? ⇒ Boolean

Returns:

  • (Boolean) 


11
12
13
 
# File 'lib/spatial_features/has_spatial_features/delayed_feature_import.rb', line 11

def updating_features?
  running_feature_update_jobs.exists?
end