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

Issues Search
    My Issues | Starred     Open | Closed | All

Side by Side Diff: appengine/findit/waterfall/test/analyze_build_failure_pipeline_test.py

Issue 2026283002: [Findit] Adding logic to force try jobs regardless of bailout or previous results (Closed) Base URL: https://chromium.googlesource.com/infra/infra.git@master
Patch Set: Addressing comments and rebase Created 4 years, 5 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
« no previous file with comments | « appengine/findit/waterfall/swarming_tasks_to_try_job_pipeline.py ('k') | appengine/findit/waterfall/test/build_failure_analysis_pipelines_test.py » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 os 5 import os
6 6
7 from common import constants 7 from common import constants
8 from common import chromium_deps 8 from common import chromium_deps
9 from common.pipeline_wrapper import pipeline_handlers 9 from common.pipeline_wrapper import pipeline_handlers
10 from model import analysis_status 10 from model import analysis_status
(...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after
99 def testBuildFailurePipeline(self): 99 def testBuildFailurePipeline(self):
100 master_name = 'm' 100 master_name = 'm'
101 builder_name = 'b' 101 builder_name = 'b'
102 build_number = 124 102 build_number = 124
103 103
104 self._Setup(master_name, builder_name, build_number) 104 self._Setup(master_name, builder_name, build_number)
105 105
106 root_pipeline = AnalyzeBuildFailurePipeline(master_name, 106 root_pipeline = AnalyzeBuildFailurePipeline(master_name,
107 builder_name, 107 builder_name,
108 build_number, 108 build_number,
109 False,
109 False) 110 False)
110 root_pipeline.start(queue_name=constants.DEFAULT_QUEUE) 111 root_pipeline.start(queue_name=constants.DEFAULT_QUEUE)
111 self.execute_queued_tasks() 112 self.execute_queued_tasks()
112 113
113 expected_analysis_result = { 114 expected_analysis_result = {
114 'failures': [ 115 'failures': [
115 { 116 {
116 'step_name': 'a', 117 'step_name': 'a',
117 'supported': True, 118 'supported': True,
118 'first_failure': 124, 119 'first_failure': 124,
(...skipping 25 matching lines...) Expand all
144 def testBuildFailurePipelineStartWithNoneResultStatus(self): 145 def testBuildFailurePipelineStartWithNoneResultStatus(self):
145 master_name = 'm' 146 master_name = 'm'
146 builder_name = 'b' 147 builder_name = 'b'
147 build_number = 124 148 build_number = 124
148 149
149 self._Setup(master_name, builder_name, build_number) 150 self._Setup(master_name, builder_name, build_number)
150 151
151 root_pipeline = AnalyzeBuildFailurePipeline(master_name, 152 root_pipeline = AnalyzeBuildFailurePipeline(master_name,
152 builder_name, 153 builder_name,
153 build_number, 154 build_number,
155 False,
154 False) 156 False)
155 root_pipeline._ResetAnalysis(master_name, builder_name, build_number) 157 root_pipeline._ResetAnalysis(master_name, builder_name, build_number)
156 analysis = WfAnalysis.Get(master_name, builder_name, build_number) 158 analysis = WfAnalysis.Get(master_name, builder_name, build_number)
157 self.assertIsNotNone(analysis) 159 self.assertIsNotNone(analysis)
158 self.assertEqual(analysis_status.RUNNING, analysis.status) 160 self.assertEqual(analysis_status.RUNNING, analysis.status)
159 self.assertIsNone(analysis.result_status) 161 self.assertIsNone(analysis.result_status)
160 162
161 def testAnalyzeBuildFailurePipelineAbortedWithAnalysis(self): 163 def testAnalyzeBuildFailurePipelineAbortedWithAnalysis(self):
162 master_name = 'm' 164 master_name = 'm'
163 builder_name = 'b' 165 builder_name = 'b'
164 build_number = 124 166 build_number = 124
165 167
166 self._Setup(master_name, builder_name, build_number) 168 self._Setup(master_name, builder_name, build_number)
167 169
168 root_pipeline = AnalyzeBuildFailurePipeline(master_name, 170 root_pipeline = AnalyzeBuildFailurePipeline(master_name,
169 builder_name, 171 builder_name,
170 build_number, 172 build_number,
173 False,
171 False) 174 False)
172 root_pipeline._LogUnexpectedAborting(True) 175 root_pipeline._LogUnexpectedAborting(True)
173 176
174 analysis = WfAnalysis.Get(master_name, builder_name, build_number) 177 analysis = WfAnalysis.Get(master_name, builder_name, build_number)
175 self.assertIsNotNone(analysis) 178 self.assertIsNotNone(analysis)
176 self.assertEqual(analysis_status.ERROR, analysis.status) 179 self.assertEqual(analysis_status.ERROR, analysis.status)
177 self.assertIsNone(analysis.result_status) 180 self.assertIsNone(analysis.result_status)
178 181
179 def testAnalyzeBuildFailurePipelineAbortedWithoutAnalysis(self): 182 def testAnalyzeBuildFailurePipelineAbortedWithoutAnalysis(self):
180 master_name = 'm' 183 master_name = 'm'
181 builder_name = 'b' 184 builder_name = 'b'
182 build_number = 124 185 build_number = 124
183 186
184 root_pipeline = AnalyzeBuildFailurePipeline(master_name, 187 root_pipeline = AnalyzeBuildFailurePipeline(master_name,
185 builder_name, 188 builder_name,
186 build_number, 189 build_number,
190 False,
187 False) 191 False)
188 root_pipeline._LogUnexpectedAborting(True) 192 root_pipeline._LogUnexpectedAborting(True)
189 193
190 analysis = WfAnalysis.Get(master_name, builder_name, build_number) 194 analysis = WfAnalysis.Get(master_name, builder_name, build_number)
191 self.assertIsNone(analysis) 195 self.assertIsNone(analysis)
192 196
193 def testAnalyzeBuildFailurePipelineNotAborted(self): 197 def testAnalyzeBuildFailurePipelineNotAborted(self):
194 master_name = 'm' 198 master_name = 'm'
195 builder_name = 'b' 199 builder_name = 'b'
196 build_number = 124 200 build_number = 124
197 201
198 self._Setup(master_name, builder_name, build_number) 202 self._Setup(master_name, builder_name, build_number)
199 203
200 root_pipeline = AnalyzeBuildFailurePipeline(master_name, 204 root_pipeline = AnalyzeBuildFailurePipeline(master_name,
201 builder_name, 205 builder_name,
202 build_number, 206 build_number,
207 False,
203 False) 208 False)
204 root_pipeline._LogUnexpectedAborting(False) 209 root_pipeline._LogUnexpectedAborting(False)
205 210
206 analysis = WfAnalysis.Get(master_name, builder_name, build_number) 211 analysis = WfAnalysis.Get(master_name, builder_name, build_number)
207 self.assertIsNotNone(analysis) 212 self.assertIsNotNone(analysis)
208 self.assertNotEqual(analysis_status.ERROR, analysis.status) 213 self.assertNotEqual(analysis_status.ERROR, analysis.status)
OLDNEW
« no previous file with comments | « appengine/findit/waterfall/swarming_tasks_to_try_job_pipeline.py ('k') | appengine/findit/waterfall/test/build_failure_analysis_pipelines_test.py » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698