| OLD | NEW |
| 1 # Copyright 2016 The Chromium Authors. All rights reserved. | 1 # Copyright 2016 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 common import appengine_util | 7 from common import appengine_util |
| 8 from common import constants | 8 from common import constants |
| 9 from common import time_util | 9 from lib import time_util |
| 10 from model import analysis_status | 10 from model import analysis_status |
| 11 from model.flake.master_flake_analysis import MasterFlakeAnalysis | 11 from model.flake.master_flake_analysis import MasterFlakeAnalysis |
| 12 from waterfall import waterfall_config | 12 from waterfall import waterfall_config |
| 13 from waterfall.flake import triggering_sources | 13 from waterfall.flake import triggering_sources |
| 14 from waterfall.flake.recursive_flake_pipeline import RecursiveFlakePipeline | 14 from waterfall.flake.recursive_flake_pipeline import RecursiveFlakePipeline |
| 15 | 15 |
| 16 | 16 |
| 17 def _NeedANewAnalysis( | 17 def _NeedANewAnalysis( |
| 18 master_name, builder_name, build_number, step_name, test_name, | 18 master_name, builder_name, build_number, step_name, test_name, |
| 19 algorithm_parameters, allow_new_analysis=False, force=False, | 19 algorithm_parameters, allow_new_analysis=False, force=False, |
| (...skipping 117 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 137 pipeline_job = RecursiveFlakePipeline( | 137 pipeline_job = RecursiveFlakePipeline( |
| 138 master_name, builder_name, build_number, step_name, test_name, | 138 master_name, builder_name, build_number, step_name, test_name, |
| 139 analysis.version_number, master_build_number=build_number, | 139 analysis.version_number, master_build_number=build_number, |
| 140 flakiness_algorithm_results_dict=flakiness_algorithm_results_dict, | 140 flakiness_algorithm_results_dict=flakiness_algorithm_results_dict, |
| 141 manually_triggered=manually_triggered) | 141 manually_triggered=manually_triggered) |
| 142 pipeline_job.target = appengine_util.GetTargetNameForModule( | 142 pipeline_job.target = appengine_util.GetTargetNameForModule( |
| 143 constants.WATERFALL_BACKEND) | 143 constants.WATERFALL_BACKEND) |
| 144 pipeline_job.StartOffPSTPeakHours(queue_name=queue_name) | 144 pipeline_job.StartOffPSTPeakHours(queue_name=queue_name) |
| 145 | 145 |
| 146 return analysis | 146 return analysis |
| OLD | NEW |