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