Sha256: 6b369ad1060c1451988cd5ebc3faf9ecbe4d1d49130ef23be94e7d4c3a377c14

Contents?: true

Size: 268 Bytes

Versions: 8

Compression:

Stored size: 268 Bytes

Contents

module Importo
  class ImportScheduledJob < ApplicationJob
    def perform()
      imports = Import.where(state: "scheduled", created_at: ..30.minutes.ago)

      imports.each do |import|
        ImportService.perform_async(import: import)
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version Path
importo-3.0.22 app/jobs/importo/import_scheduled_job.rb
importo-3.0.21 app/jobs/importo/import_scheduled_job.rb
importo-3.0.20 app/jobs/importo/import_scheduled_job.rb
importo-3.0.19 app/jobs/importo/import_scheduled_job.rb
importo-3.0.18 app/jobs/importo/import_scheduled_job.rb
importo-3.0.17 app/jobs/importo/import_scheduled_job.rb
importo-3.0.16 app/jobs/importo/import_scheduled_job.rb
importo-3.0.15 app/jobs/importo/import_scheduled_job.rb