OLD | NEW |
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 from pipeline_utils.appengine_third_party_pipeline_src_pipeline import handlers | 5 from pipeline_utils.appengine_third_party_pipeline_src_pipeline import handlers |
6 from testing_utils import testing | 6 from testing_utils import testing |
7 | 7 |
8 from model.wf_analysis import WfAnalysis | 8 from model.wf_analysis import WfAnalysis |
9 from model import wf_analysis_status | 9 from model import wf_analysis_status |
10 from model import wf_analysis_result_status | 10 from model import wf_analysis_result_status |
(...skipping 195 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
206 analysis.result = None | 206 analysis.result = None |
207 analysis.status = wf_analysis_status.ANALYZING | 207 analysis.status = wf_analysis_status.ANALYZING |
208 analysis.put() | 208 analysis.put() |
209 | 209 |
210 failure_info = { | 210 failure_info = { |
211 'master_name': master_name, | 211 'master_name': master_name, |
212 'builder_name': builder_name, | 212 'builder_name': builder_name, |
213 'build_number': build_number, | 213 'build_number': build_number, |
214 } | 214 } |
215 change_logs = {} | 215 change_logs = {} |
| 216 deps_info = {} |
216 signals = {} | 217 signals = {} |
217 | 218 |
218 dummy_result = {'failures': []} | 219 dummy_result = {'failures': []} |
219 | 220 |
220 def MockAnalyzeBuildFailure(*_): | 221 def MockAnalyzeBuildFailure(*_): |
221 return dummy_result | 222 return dummy_result |
222 | 223 |
223 self.mock(build_failure_analysis, | 224 self.mock(build_failure_analysis, |
224 'AnalyzeBuildFailure', MockAnalyzeBuildFailure) | 225 'AnalyzeBuildFailure', MockAnalyzeBuildFailure) |
225 | 226 |
226 pipeline = identify_culprit_pipeline.IdentifyCulpritPipeline( | 227 pipeline = identify_culprit_pipeline.IdentifyCulpritPipeline( |
227 failure_info, change_logs, signals) | 228 failure_info, change_logs, deps_info, signals) |
228 pipeline.start() | 229 pipeline.start() |
229 self.execute_queued_tasks() | 230 self.execute_queued_tasks() |
230 | 231 |
231 expected_suspected_cls = [] | 232 expected_suspected_cls = [] |
232 | 233 |
233 analysis = WfAnalysis.Get(master_name, builder_name, build_number) | 234 analysis = WfAnalysis.Get(master_name, builder_name, build_number) |
234 self.assertIsNotNone(analysis) | 235 self.assertIsNotNone(analysis) |
235 self.assertEqual(dummy_result, analysis.result) | 236 self.assertEqual(dummy_result, analysis.result) |
236 self.assertEqual(wf_analysis_status.ANALYZED, analysis.status) | 237 self.assertEqual(wf_analysis_status.ANALYZED, analysis.status) |
237 self.assertIsNone(analysis.result_status) | 238 self.assertIsNone(analysis.result_status) |
238 self.assertEqual(expected_suspected_cls, analysis.suspected_cls) | 239 self.assertEqual(expected_suspected_cls, analysis.suspected_cls) |
OLD | NEW |