exercism/analyzer-pipeline
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Periodically emit list of deployed versions from worker

Browse Source
This commit is contained in:
Charles Care
2019-12-20 14:34:32 +00:00
parent b2122d6a7a
commit 6f0ed2c501
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
lib/pipeline/rpc/router.rb
View File

@@ -92,6 +92,7 @@ module Pipeline::Rpc
elsif msg.type == "worker_heartbeat" elsif msg.type == "worker_heartbeat"
identity = msg.parsed_msg["identity"] identity = msg.parsed_msg["identity"]
queues = msg.parsed_msg["workqueue_addresses"] queues = msg.parsed_msg["workqueue_addresses"]
puts "worker heartbeat #{msg.parsed_msg}"
@worker_presence.mark_seen!(identity, queues) @worker_presence.mark_seen!(identity, queues)
else else
puts "Unrecognised message: #{msg.type} #{msg.parsed_msg}" puts "Unrecognised message: #{msg.type} #{msg.parsed_msg}"

7
lib/pipeline/runtime/runtime_environment.rb
View File

@@ -51,11 +51,10 @@ module Pipeline::Runtime
release_container(language_slug, version, container_repo) release_container(language_slug, version, container_repo)
end end
def list_deployed_containers(track_slug) def list_deployed_containers
track_dir = "#{env_base}/#{track_slug}" glob_pattern = "#{env_base}/*/*/current"
glob_pattern = "#{track_dir}/*/current"
Dir.glob(glob_pattern).map do |match| Dir.glob(glob_pattern).map do |match|
match.gsub(track_dir, "").gsub(/current$/, "") match.gsub(env_base, "").gsub(/current$/, "")
end end
end end