6
6
7
7
from ruamel .yaml import YAML
8
8
9
- RELEASES_URL = "https://raw.githubusercontent.com/elastic/ logstash/main/ ci/logstash_releases.json "
9
+ RELEASES_URL = "https://raw.githubusercontent.com/logstash-plugins/. ci/refs/heads/1.x/logstash-versions.yml "
10
10
TEST_MATRIX_URL = "https://raw.githubusercontent.com/elastic/logstash-filter-elastic_integration/main/.buildkite/pull" \
11
11
"-request-test-matrix.yml"
12
12
TEST_COMMAND : typing .final = ".buildkite/scripts/run_tests.sh"
@@ -61,14 +61,16 @@ def make_matrix_version_key(branch: str) -> str:
61
61
structure = {
62
62
"agents" : {
63
63
"provider" : "gcp" ,
64
- "machineType" : "n1-standard-4" ,
65
- "image" : "family/core-ubuntu-2204"
64
+ "machineType" : "n2-standard-4" ,
65
+ "imageProject" : "elastic-images-prod" ,
66
+ "image" : "family/platform-ingest-logstash-multi-jdk-ubuntu-2204"
66
67
},
67
68
"steps" : []}
68
69
69
70
steps = []
70
71
response = call_url_with_retry (RELEASES_URL )
71
- versions_json = response .json ()
72
+ yaml = YAML (typ = 'safe' )
73
+ versions_yaml : typing .final = yaml .load (response .text )
72
74
73
75
matrix_map = call_url_with_retry (TEST_MATRIX_URL )
74
76
matrix_map_yaml = YAML ().load (matrix_map .text )
@@ -88,13 +90,13 @@ def make_matrix_version_key(branch: str) -> str:
88
90
print (f"matrix_releases: { matrix_releases } " )
89
91
print (f"matrix_snapshots: { matrix_snapshots } " )
90
92
for matrix_release in matrix_releases :
91
- full_stack_version : typing .final = versions_json ["releases" ].get (matrix_release )
93
+ full_stack_version : typing .final = versions_yaml ["releases" ].get (matrix_release )
92
94
# noop, if they are declared in the matrix but not in the release
93
95
if full_stack_version is not None :
94
96
steps += generate_unit_and_integration_test_steps (full_stack_version , "false" )
95
97
96
98
for matrix_snapshot in matrix_snapshots :
97
- full_stack_version : typing .final = versions_json ["snapshots" ].get (matrix_snapshot )
99
+ full_stack_version : typing .final = versions_yaml ["snapshots" ].get (matrix_snapshot )
98
100
# noop, if they are declared in the matrix but not in the snapshot
99
101
if full_stack_version is not None :
100
102
steps += generate_unit_and_integration_test_steps (full_stack_version , "true" )
0 commit comments