This commit is contained in:
isaac-hammes 2023-09-07 08:31:29 -07:00
parent 8d818fe105
commit 77d88621bb

View file

@ -104,7 +104,7 @@ module Vmpooler
@redis.with_metrics do |redis| @redis.with_metrics do |redis|
request_id = redis.hget("vmpooler__vm__#{vm}", 'request_id') request_id = redis.hget("vmpooler__vm__#{vm}", 'request_id')
if provider.vm_ready?(pool, vm, redis) if provider.vm_ready?(pool, vm, redis)
move_pending_vm_to_ready(vm, pool, redis, request_id) move_pending_vm_to_ready(vm, pool, redis, request_id, provider)
else else
fail_pending_vm(vm, pool, timeout, timeout_notification, redis) fail_pending_vm(vm, pool, timeout, timeout_notification, redis)
end end
@ -172,7 +172,7 @@ module Vmpooler
open_socket_error open_socket_error
end end
def move_pending_vm_to_ready(vm, pool, redis, request_id = nil) def move_pending_vm_to_ready(vm, pool, redis, request_id = nil, provider = nil)
clone_time = redis.hget("vmpooler__vm__#{vm}", 'clone') clone_time = redis.hget("vmpooler__vm__#{vm}", 'clone')
finish = format('%<time>.2f', time: Time.now - Time.parse(clone_time)) finish = format('%<time>.2f', time: Time.now - Time.parse(clone_time))