lib/qpush/server/apis/setup.rb in qpush-0.1.4 vs lib/qpush/server/apis/setup.rb in qpush-0.1.6

- old
+ new

@@ -1,13 +1,9 @@ module QPush module Server module Apis class Setup < Base - def initialize(job) - @job = job - end - def call invalid_job && return unless @job.valid? setup_job end @@ -17,10 +13,10 @@ Perform.call(@job) if @job.perform_job? Delay.call(@job, :delay) if @job.delay_job? end def invalid_job - Server.log.err("Job INVALID | #{@job.klass} | #{@job.id} | #{@job.errors.full_messages.join(' ')}") + Server.log.err("Worker #{Server.worker.id} | Job INVALID | #{@job.klass} | #{@job.id} | #{@job.errors.full_messages.join(' ')}") end end end end end