1
0
mirror of synced 2025-12-25 02:09:19 -05:00

Add version prefix to build status files (#22126)

This commit is contained in:
Ben Church
2023-01-30 20:59:40 -08:00
committed by GitHub
parent a9d85e3e06
commit 1f2b6d619b
3 changed files with 7 additions and 3 deletions

View File

@@ -33,7 +33,7 @@ class BUILD_STATUSES(str, Enum):
def get_connector_build_output_url(connector_technical_name: str, connector_version: str) -> str:
return f"{CONNECTOR_BUILD_OUTPUT_URL}/{connector_technical_name}/{connector_version}.json"
return f"{CONNECTOR_BUILD_OUTPUT_URL}/{connector_technical_name}/version-{connector_version}.json"
def fetch_latest_build_status_for_connector_version(connector_technical_name: str, connector_version: str) ->BUILD_STATUSES:
"""Fetch the latest build status for a given connector version."""

View File

@@ -121,7 +121,7 @@ def test_fetch_latest_build_status_for_connector_version(mocker, connector_name,
mock_get = mocker.patch.object(requests, 'get', return_value=mock_response)
assert inputs.fetch_latest_build_status_for_connector_version(connector_name, connector_version) == expected_status
assert mock_get.call_args == call(f"{constants.CONNECTOR_BUILD_OUTPUT_URL}/{connector_name}/{connector_version}.json")
assert mock_get.call_args == call(f"{constants.CONNECTOR_BUILD_OUTPUT_URL}/{connector_name}/version-{connector_version}.json")
def test_fetch_latest_build_status_for_connector_version_invalid_status(mocker, caplog):
connector_name = "connectors/source-pokeapi"

View File

@@ -22,6 +22,7 @@ fi
BUCKET_WRITE_ROOT=/tmp/bucket_write_root
LAST_TEN_ROOT=/tmp/last_ten_root
SUMMARY_WRITE_ROOT=/tmp/summary_write_root
VERSION_PREFIX="version-"
DOCKER_VERSION=$(get_connector_version "$CONNECTOR")
@@ -65,8 +66,11 @@ function write_job_log() {
function pull_latest_job_logs() {
# pull the logs for the latest ten jobs for this connector
# note this is done by key as each log has a timestamp in the filename
# ensuring that the version specific runs are filtered out.
LAST_TEN_FILES=$(aws s3api list-objects-v2 --bucket "$BUCKET" \
--query "reverse(sort_by(Contents[?contains(Key, \`tests/history/$CONNECTOR\`)], &LastModified))[:10].Key" \
--prefix "tests/history/$CONNECTOR" \
--query "reverse(sort_by(Contents[?!contains(Key, \`$VERSION_PREFIX\`)], &Key))[:10].Key" \
--output=text)
rm -r $LAST_TEN_ROOT || true