From c5264401ee933af5a70a4a35f831e3c65096ef9c Mon Sep 17 00:00:00 2001 From: Anton Chuchkalov Date: Wed, 2 Sep 2015 12:50:24 +0300 Subject: [PATCH] add ability to start workers synchronously --- devops-service/workers/worker.rb | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/devops-service/workers/worker.rb b/devops-service/workers/worker.rb index c3da35c..9ca1515 100644 --- a/devops-service/workers/worker.rb +++ b/devops-service/workers/worker.rb @@ -34,6 +34,14 @@ class Worker uri.to_s end + def self.start_sync(worker_class, request, job_options) + stringified_options = {} + job_options.each do |key, value| + stringified_options[key.to_s] = value + end + worker_class.new.perform(stringified_options) + end + def self.set_status id, status Sidekiq.redis {|con| con.hset "devops", id, status} end @@ -86,7 +94,7 @@ class Worker end # outputs to STDOUT - def call_sync + def call_sync(provider) out = STDOUT begin yield(provider, out, '')