| 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 |