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

Fixup bug when no backends are available

Browse Source
This commit is contained in:
Charles Care
2019-12-11 09:53:17 +00:00
parent 5506c0a9bd
commit dcd88e250a
1 changed files with 16 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -197,21 +197,25 @@ module Pipeline::Rpc
addresses = []
track_slug = req.parsed_msg["track_slug"]
backend = channel[track_slug]
addresses << backend.public_address
if backend && backend.worker_available?
forward(backend, req)
return
if backend
addresses << backend.public_address
if backend.worker_available?
forward(backend, req)
return
end
end
backend = channel["*"]
addresses << backend.public_address
if backend && backend.worker_available?
forward(backend, req)
else
info = {
current_worker_count: @worker_presence.count_for(addresses)
}
req.send_error("No workers available for <#{track_slug}>", 503, info)
if backend
addresses << backend.public_address
if backend.worker_available?
forward(backend, req)
return
end
end
info = {
current_worker_count: @worker_presence.count_for(addresses)
}
req.send_error("No workers available for <#{track_slug}>", 503, info)
end
def forward(backend, req)