#840: worker options keys to symbols
This commit is contained in:
parent
8af43f658d
commit
a3cb07ab5c
@ -13,6 +13,8 @@ require "core/devops-db"
|
||||
require "providers/provider_factory"
|
||||
require "lib/knife/knife_factory"
|
||||
|
||||
|
||||
# All options keys MUST be a symbol!!!
|
||||
class Worker
|
||||
include Sidekiq::Worker
|
||||
|
||||
@ -27,7 +29,7 @@ class Worker
|
||||
end
|
||||
|
||||
def self.start_async(worker_class, request, job_options)
|
||||
jid = worker_class.perform_async(job_options.dup)
|
||||
jid = worker_class.perform_async(convert_config(job_options))
|
||||
Worker.set_status jid, Worker::STATUS::IN_QUEUE
|
||||
DevopsLogger.logger.info "Job '#{jid}' has been queued"
|
||||
|
||||
@ -37,10 +39,12 @@ class Worker
|
||||
end
|
||||
|
||||
def self.start_sync(worker_class, request, job_options, out)
|
||||
stringified_options = {}
|
||||
stringified_options = convert_config(job_options)
|
||||
=begin
|
||||
job_options.each do |key, value|
|
||||
stringified_options[key.to_s] = value
|
||||
end
|
||||
=end
|
||||
w = worker_class.new
|
||||
w.out = out
|
||||
w.perform(stringified_options)
|
||||
|
||||
Loading…
Reference in New Issue
Block a user