mirror of
https://github.com/elastic/logstash.git
synced 2025-04-22 21:57:26 -04:00
15e19a96c2
The current mechanism of discovering the latest released version per branch (via ARTIFACTS_API) isn't foolproof near the time of a new release, as it may be pick a version that hasn't been released yet. This leads to failures[^1] of the packaging upgrade tests, as we attempt to download a package file that doesn't exist yet. This commit switches to an API that that is more up to date regarding the release version truth. [^1]: https://buildkite.com/elastic/logstash-exhaustive-tests-pipeline/builds/125#018d319b-9a33-4306-b7f2-5b41937a8881/1033-1125
52 lines
1.7 KiB
Ruby
52 lines
1.7 KiB
Ruby
# Licensed to Elasticsearch B.V. under one or more contributor
|
|
# license agreements. See the NOTICE file distributed with
|
|
# this work for additional information regarding copyright
|
|
# ownership. Elasticsearch B.V. licenses this file to you under
|
|
# the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing,
|
|
# software distributed under the License is distributed on an
|
|
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
# KIND, either express or implied. See the License for the
|
|
# specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
require 'net/http'
|
|
|
|
ARTIFACT_VERSIONS_API = "https://storage.googleapis.com/artifacts-api/releases.properties"
|
|
|
|
def logstash_download_metadata(version, arch, artifact_type)
|
|
filename = "logstash-#{version}-#{arch}.#{artifact_type}"
|
|
{ url: "https://artifacts.elastic.co/downloads/logstash/#{filename}", dest: File.join(ROOT, 'qa', filename) }
|
|
end
|
|
|
|
def fetch_latest_logstash_release_version(branch)
|
|
uri = URI(ARTIFACT_VERSIONS_API)
|
|
major = branch.split('.').first
|
|
|
|
response = retryable_http_get(uri)
|
|
|
|
response.match(/current_#{major}=(\S+)/)&.captures&.first
|
|
end
|
|
|
|
def retryable_http_get(uri, max_retries=5, retry_wait=10)
|
|
count = 0
|
|
|
|
begin
|
|
response = Net::HTTP.get(uri)
|
|
rescue StandardError => e
|
|
count += 1
|
|
if count < max_retries
|
|
puts "Retry attempt #{count}/#{max_retries}: #{e.message}"
|
|
sleep(retry_wait)
|
|
retry
|
|
else
|
|
puts "Exhausted all attempts trying to get from #{uri}."
|
|
raise e
|
|
end
|
|
end
|
|
end
|