Contents

module Ddr::Batch
  class BatchProcessorJob
    @queue = :batch

    def self.perform(batch_id, operator_id)
      ts = Time.now.strftime("%Y%m%d%H%M%S%L")
      logfile = "batch_processor_#{ts}_log.txt"
      batch = Batch.find(batch_id)
      operator = User.find(operator_id)
      bp = BatchProcessor.new(batch, operator, log_file: logfile)
      bp.execute
    end

    def self.after_enqueue_set_status(batch_id, operator_id)
      batch = Batch.find(batch_id)
      batch.status = Batch::STATUS_QUEUED
      batch.save
    end

  end
end

Version data entries

24 entries across 24 versions & 1 rubygems

Version	Path
ddr-batch-1.1.0	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-1.1.0.rc2	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-1.1.0.rc1	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-2.0.1	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-2.0.0.rc3	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-2.0.0.rc2	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-2.0.0.rc1	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-2.0.0.beta.6	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-2.0.0.beta.5	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-2.0.0.beta.4	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-2.0.0.beta.3	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-2.0.0.beta.2	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-2.0.0.beta.1	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-2.0.0.alpha.3	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-1.0.2	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-1.0.2.rc1	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-2.0.0.alpha.2	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-2.0.0.alpha.1	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-1.0.1	app/jobs/ddr/batch/batch_processor_job.rb
ddr-batch-1.0.0	app/jobs/ddr/batch/batch_processor_job.rb