Sha256: aeb4ae199709c81489d38b1df64c6f0fd988869a46f0a8d66caf3b8b0fa630f8

Contents?: true

Size: 551 Bytes

Versions: 10

Compression:

Stored size: 551 Bytes

Contents

class ExportJob < Struct.new(:export, :filename, :type, :base_uri)
  def enqueue(job)
    job.delayed_reference_id   = export.id
    job.delayed_reference_type = export.class.to_s
    job.delayed_global_reference_id = export.to_global_id
    job.save!
  end

  def perform
    strio = StringIO.new

    exporter = SkosExporter.new(filename, type, base_uri, Logger.new(strio))
    exporter.run
    @messages = strio.string
  end

  def success(job)
    export.finish!(@messages)
  end

  def error(job, exception)
    export.fail!(exception)
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version Path
iqvoc-4.14.5 app/jobs/export_job.rb
iqvoc-4.14.4 app/jobs/export_job.rb
iqvoc-4.13.2 app/jobs/export_job.rb
iqvoc-4.13.0 app/jobs/export_job.rb
iqvoc-4.12.1 app/jobs/export_job.rb
iqvoc-4.12.0 app/jobs/export_job.rb
iqvoc-4.11.1 app/jobs/export_job.rb
iqvoc-4.11.0 app/jobs/export_job.rb
iqvoc-4.10.0 app/jobs/export_job.rb
iqvoc-4.9.0 app/jobs/export_job.rb