Sha256: 1e16695deba83a8a9573f89c1731ac8ce0e4e5736defb53b65cb5536aed0d8df

Contents?: true

Size: 372 Bytes

Versions: 6

Compression:

Stored size: 372 Bytes

Contents

module AsyncRequest
  class JobProcessor
    include Sidekiq::Worker

    def perform(id)
      job = Job.find(id)
      job.processing!
      status, response = job.worker.constantize.new.execute(*job.params)
      job.update_attributes!(
        status: Job.statuses[:processed],
        status_code: status,
        response: response.to_json
      )
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
async_request-0.0.6 app/workers/async_request/job_processor.rb
async_request-0.0.5 app/workers/async_request/job_processor.rb
async_request-0.0.4 app/workers/async_request/job_processor.rb
async_request-0.0.3 app/workers/async_request/job_processor.rb
async_request-0.0.2 app/workers/async_request/job_processor.rb
async_request-0.0.1 app/workers/async_request/job_processor.rb