@@ -45,45 +45,29 @@ def generate_test_step(stack_version, es_treeish, snapshot) -> dict:
45
45
46
46
steps = []
47
47
response = call_url_with_retry (RELEASES_URL )
48
- < << << << HEAD
49
- versions_json = response . json ( )
48
+ yaml = YAML ( typ = 'safe' )
49
+ versions_yaml : typing . final = yaml . load ( response . text )
50
50
51
51
# there are situations to manually run CIs with PR change,
52
52
# set MANUAL_TARGET_BRANCH with upstream target branch and run
53
53
manually_set_target_branch : typing .final = os .getenv ("MANUAL_TARGET_BRANCH" )
54
54
target_branch : typing .final = manually_set_target_branch if manually_set_target_branch else os .getenv ("TARGET_BRANCH" )
55
55
print (f"Running with target_branch: { target_branch } " )
56
56
if target_branch == '8.x' :
57
- full_stack_version : typing .final = versions_json ["snapshots" ]["8.future" ]
57
+ full_stack_version : typing .final = versions_yaml ["snapshots" ]["8.future" ]
58
58
steps .append (generate_test_step (full_stack_version , target_branch , "true" ))
59
59
elif target_branch == 'main' :
60
- full_stack_version : typing .final = versions_json ["snapshots" ][target_branch ]
60
+ full_stack_version : typing .final = versions_yaml ["snapshots" ][target_branch ]
61
61
steps .append (generate_test_step (full_stack_version , target_branch , "true" ))
62
62
else :
63
63
# generate steps for the version if released
64
- releases = versions_json ["releases" ]
64
+ releases = versions_yaml ["releases" ]
65
65
for release_version in releases :
66
66
if releases [release_version ].startswith (target_branch ):
67
67
steps .append (generate_test_step (releases [release_version ], target_branch , "false" ))
68
68
break
69
- == == == =
70
- yaml = YAML (typ = 'safe' )
71
- versions_yaml : typing .final = yaml .load (response .text )
72
-
73
- # Use BUILDKITE_SOURCE to figure out PR merge or schedule.
74
- # If PR merge, no need to run builds on all branches, target branch will be good
75
- # - webhook when PR gets merged
76
- # - schedule when daily schedule starts
77
- # - ui when manually kicking job from BK UI
78
- # - manual kick off will be on PR or entire main branch, can be decided with BUILDKITE_BRANCH
79
- bk_source = os .getenv ("BUILDKITE_SOURCE" )
80
- bk_branch = os .getenv ("BUILDKITE_BRANCH" )
81
- steps = generate_steps_for_scheduler (versions_yaml ) if (bk_source == "schedule" or bk_branch == "main" ) \
82
- else generate_steps_for_main_branch (versions_yaml )
83
- >> >> >> > febb207 (Update buildkite script to look for new logstash releases location (#358))
84
-
85
69
# steps for snapshot version
86
- snapshots = versions_json ["snapshots" ]
70
+ snapshots = versions_yaml ["snapshots" ]
87
71
for snapshot_version in snapshots :
88
72
if snapshots [snapshot_version ].startswith (target_branch ):
89
73
steps .append (generate_test_step (snapshots [snapshot_version ], target_branch , "false" ))
0 commit comments