diff --git a/lib/pipeline/rpc/router.rb b/lib/pipeline/rpc/router.rb index 6ba7aec..810692f 100644 --- a/lib/pipeline/rpc/router.rb +++ b/lib/pipeline/rpc/router.rb @@ -167,8 +167,10 @@ module Pipeline::Rpc end workers = @worker_presence.list_for(addresses) deployed_versions = Hash.new {|h,k| h[k] = Hash.new {|h,k| h[k] = []} } - target_versions.each do |lang, version| - deployed_versions[lang][version] = [] + target_versions.each do |lang, versions| + versions.each do |version| + deployed_versions[lang][version] = [] + end end worker_ids = [] workers.each do |worker|