Class: Massive::FileJob

Inherits:
Job
  • Object
show all
Defined in:
lib/massive/file_job.rb

Instance Method Summary collapse

Methods inherited from Job

cancel_when_failed, #enqueue, #finish!, perform, #process_each, queue, queue_prefix, split_jobs, #work

Methods included from Cancelling

#cancelled?, #cancelling

Methods included from Retry

#retrying

Methods included from TimingSupport

#elapsed_time

Methods included from MemoryConsumption

#current_memory_consumption

Methods included from Status

#completed?, #enqueued?, #failed?, #start!, #started?

Instance Method Details

#each_item(&block) ⇒ Object 



5
6
7
 
# File 'lib/massive/file_job.rb', line 5

def each_item(&block)
  file.processor.process_range(offset: offset + processed, limit: limit - processed, &block)
end