Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(368)

Side by Side Diff: appengine/findit/waterfall/try_job_util.py

Issue 1898493002: [Findit] Adding support for disabling test try jobs for given master/builder (Closed) Base URL: https://chromium.googlesource.com/infra/infra.git@master
Patch Set: Created 4 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 # Copyright 2015 The Chromium Authors. All rights reserved. 1 # Copyright 2015 The Chromium Authors. All rights reserved.
2 # Use of this source code is governed by a BSD-style license that can be 2 # Use of this source code is governed by a BSD-style license that can be
3 # found in the LICENSE file. 3 # found in the LICENSE file.
4 4
5 import logging 5 import logging
6 6
7 from google.appengine.ext import ndb 7 from google.appengine.ext import ndb
8 8
9 from common import appengine_util 9 from common import appengine_util
10 from common import constants 10 from common import constants
(...skipping 134 matching lines...) Expand 10 before | Expand all | Expand 10 after
145 145
146 def ScheduleTryJobIfNeeded(failure_info, signals, heuristic_result): 146 def ScheduleTryJobIfNeeded(failure_info, signals, heuristic_result):
147 master_name = failure_info['master_name'] 147 master_name = failure_info['master_name']
148 builder_name = failure_info['builder_name'] 148 builder_name = failure_info['builder_name']
149 build_number = failure_info['build_number'] 149 build_number = failure_info['build_number']
150 failed_steps = failure_info.get('failed_steps', []) 150 failed_steps = failure_info.get('failed_steps', [])
151 builds = failure_info.get('builds', {}) 151 builds = failure_info.get('builds', {})
152 152
153 tryserver_mastername, tryserver_buildername = ( 153 tryserver_mastername, tryserver_buildername = (
154 waterfall_config.GetTrybotForWaterfallBuilder(master_name, builder_name)) 154 waterfall_config.GetTrybotForWaterfallBuilder(master_name, builder_name))
155 if not tryserver_mastername or not tryserver_buildername: 155 if ((not tryserver_mastername or not tryserver_buildername) or
156 not waterfall_config.EnableTestTryJobs(master_name, builder_name)):
stgao 2016/04/16 01:04:04 What if the try-job to run is for compile? also di
lijeffrey 2016/04/16 02:57:27 Done.
156 logging.info('%s, %s is not supported yet.', master_name, builder_name) 157 logging.info('%s, %s is not supported yet.', master_name, builder_name)
157 return {} 158 return {}
158 159
159 failure_result_map = {} 160 failure_result_map = {}
160 need_new_try_job, last_pass, try_job_type, targeted_tests = ( 161 need_new_try_job, last_pass, try_job_type, targeted_tests = (
161 _NeedANewTryJob(master_name, builder_name, build_number, 162 _NeedANewTryJob(master_name, builder_name, build_number,
162 failed_steps, failure_result_map)) 163 failed_steps, failure_result_map))
163 164
164 if need_new_try_job: 165 if need_new_try_job:
165 compile_targets = (_GetFailedTargetsFromSignals( 166 compile_targets = (_GetFailedTargetsFromSignals(
166 signals, master_name, builder_name) 167 signals, master_name, builder_name)
167 if try_job_type == TryJobType.COMPILE else None) 168 if try_job_type == TryJobType.COMPILE else None)
168 suspected_revisions = ( 169 suspected_revisions = (
169 _GetSuspectsForCompileFailureFromHeuristicResult(heuristic_result) 170 _GetSuspectsForCompileFailureFromHeuristicResult(heuristic_result)
170 if try_job_type == TryJobType.COMPILE else None) 171 if try_job_type == TryJobType.COMPILE else None)
171 172
172 pipeline = ( 173 pipeline = (
173 swarming_tasks_to_try_job_pipeline.SwarmingTasksToTryJobPipeline( 174 swarming_tasks_to_try_job_pipeline.SwarmingTasksToTryJobPipeline(
174 master_name, builder_name, build_number, 175 master_name, builder_name, build_number,
175 builds[str(last_pass)]['chromium_revision'], 176 builds[str(last_pass)]['chromium_revision'],
176 builds[str(build_number)]['chromium_revision'], 177 builds[str(build_number)]['chromium_revision'],
177 builds[str(build_number)]['blame_list'], 178 builds[str(build_number)]['blame_list'],
178 try_job_type, compile_targets, targeted_tests, suspected_revisions)) 179 try_job_type, compile_targets, targeted_tests, suspected_revisions))
179 180
180 pipeline.target = appengine_util.GetTargetNameForModule( 181 pipeline.target = appengine_util.GetTargetNameForModule(
181 constants.WATERFALL_BACKEND) 182 constants.WATERFALL_BACKEND)
182 pipeline.start(queue_name=constants.WATERFALL_TRY_JOB_QUEUE) 183 pipeline.start(queue_name=constants.WATERFALL_TRY_JOB_QUEUE)
183 184
184 if try_job_type == TryJobType.TEST: # pragma: no cover 185 if try_job_type == TryJobType.TEST: # pragma: no cover
185 logging_str = ( 186 logging_str = (
186 'Swarming task was scheduled for build %s, %s, %s: %s because of' 187 'Swarming task was scheduled for build %s, %s, %s: %s because of'
187 ' %s failure. A try job may be triggered if some reliable failure' 188 ' %s failure. A try job may be triggered if some reliable failure'
188 ' is detected in the task.') % ( 189 ' is detected in the task.') % (
189 master_name, builder_name, build_number, 190 master_name, builder_name, build_number,
190 pipeline.pipeline_status_path, try_job_type) 191 pipeline.pipeline_status_path, try_job_type)
191 else: # pragma: no cover 192 else: # pragma: no cover
192 logging_str = ( 193 logging_str = (
193 'Try job was scheduled for build %s, %s, %s: %s because of %s ' 194 'Try job was scheduled for build %s, %s, %s: %s because of %s '
194 'failure.') % ( 195 'failure.') % (
195 master_name, builder_name, build_number, 196 master_name, builder_name, build_number,
196 pipeline.pipeline_status_path, try_job_type) 197 pipeline.pipeline_status_path, try_job_type)
197 logging.info(logging_str) 198 logging.info(logging_str)
198 199
199 return failure_result_map 200 return failure_result_map
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698