Class: ImportJob
- Inherits:
-
Struct
- Object
- Struct
- ImportJob
- Defined in:
- app/jobs/import_job.rb
Instance Attribute Summary collapse
-
#filename ⇒ Object
Returns the value of attribute filename.
-
#import ⇒ Object
Returns the value of attribute import.
-
#namespace ⇒ Object
Returns the value of attribute namespace.
-
#publish ⇒ Object
Returns the value of attribute publish.
-
#user ⇒ Object
Returns the value of attribute user.
Instance Method Summary collapse
Instance Attribute Details
#filename ⇒ Object
Returns the value of attribute filename
1 2 3 |
# File 'app/jobs/import_job.rb', line 1 def filename @filename end |
#import ⇒ Object
Returns the value of attribute import
1 2 3 |
# File 'app/jobs/import_job.rb', line 1 def import @import end |
#namespace ⇒ Object
Returns the value of attribute namespace
1 2 3 |
# File 'app/jobs/import_job.rb', line 1 def namespace @namespace end |
#publish ⇒ Object
Returns the value of attribute publish
1 2 3 |
# File 'app/jobs/import_job.rb', line 1 def publish @publish end |
#user ⇒ Object
Returns the value of attribute user
1 2 3 |
# File 'app/jobs/import_job.rb', line 1 def user @user end |
Instance Method Details
#enqueue(job) ⇒ Object
3 4 5 6 7 8 |
# File 'app/jobs/import_job.rb', line 3 def enqueue(job) job.delayed_reference_id = import.id job.delayed_reference_type = import.class.to_s job.delayed_global_reference_id = import.to_global_id job.save! end |
#error(job, exception) ⇒ Object
22 23 24 |
# File 'app/jobs/import_job.rb', line 22 def error(job, exception) import.fail!(exception) end |
#perform ⇒ Object
10 11 12 13 14 15 16 |
# File 'app/jobs/import_job.rb', line 10 def perform strio = StringIO.new importer = SkosImporter.new(filename, namespace, Logger.new(strio), publish) importer.run @messages = strio.string end |
#success(job) ⇒ Object
18 19 20 |
# File 'app/jobs/import_job.rb', line 18 def success(job) import.finish!(@messages) end |