Sha256: 3720fc6a96d3e204a10c00e641469eedfe359700d37d9e8d24f6e5bab5c09030
Contents?: true
Size: 1.71 KB
Versions: 7
Compression:
Stored size: 1.71 KB
Contents
require 'aptible/api'
module Aptible
module CLI
module Helpers
module Operation
include Helpers::Ssh
POLL_INTERVAL = 1
def poll_for_success(operation)
wait_for_completion operation
return if operation.status == 'succeeded'
raise Thor::Error, "Operation ##{operation.id} failed."
end
def wait_for_completion(operation)
while %w(queued running).include? operation.status
sleep 1
operation.get
end
end
def attach_to_operation_logs(operation)
# TODO: This isn't actually guaranteed to connect to the operation
# logs, since the action will depend on what operation we're actually
# connecting for. There might be ways to make this better.
ENV['ACCESS_TOKEN'] = fetch_token
code = connect_to_ssh_portal(
operation,
'-o', 'SendEnv=ACCESS_TOKEN'
)
# If the portal is down, fall back to polling for success. If the
# operation failed, poll_for_success will immediately fall through to
# the error message.
unless code == 0
puts 'Disconnected from logs, waiting for operation to complete'
poll_for_success(operation)
end
end
def cancel_operation(operation)
puts "Cancelling #{prettify_operation(operation)}..."
operation.update!(cancelled: true)
end
def prettify_operation(o)
bits = [o.status, o.type, "##{o.id}"]
if o.resource.respond_to?(:handle)
bits.concat ['on', o.resource.handle]
end
bits.join ' '
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems