Periodically emit channel/topic/version information from worker

This commit is contained in:
Charles Care
2019-12-20 15:10:02 +00:00
parent a21f7a26bb
commit 88b9417ef8

View File

@@ -53,11 +53,11 @@ module Pipeline::Runtime
def list_deployed_containers
glob_pattern = "#{env_base}/*/*/current"
versions = {}
versions = Hash.new {|h,k| h[k] = [] }
Dir.glob(glob_pattern).map do |match|
folder = match.gsub("#{env_base}/", "").gsub(/\/current$/, "")
track_slug,version = folder.split("/")
versions[track_slug] = version
versions[track_slug] << version
end
versions
end