| Index: appengine/findit/waterfall/swarming_tasks_to_try_job_pipeline.py
|
| diff --git a/appengine/findit/waterfall/swarming_tasks_to_try_job_pipeline.py b/appengine/findit/waterfall/swarming_tasks_to_try_job_pipeline.py
|
| index e0b6f3932b7f5ac481539efaab151c0f342f792b..954e975693a4e6d7fdb894ad9470af1a9a533c30 100644
|
| --- a/appengine/findit/waterfall/swarming_tasks_to_try_job_pipeline.py
|
| +++ b/appengine/findit/waterfall/swarming_tasks_to_try_job_pipeline.py
|
| @@ -46,7 +46,7 @@ class SwarmingTasksToTryJobPipeline(BasePipeline):
|
| def run(
|
| self, master_name, builder_name, build_number, good_revision,
|
| bad_revision, blame_list, try_job_type, compile_targets=None,
|
| - targeted_tests=None, suspected_cls=None):
|
| + targeted_tests=None, suspected_cls=None, force_try_job=False):
|
|
|
| # A list contains tuples of step_names and classified_tests from
|
| # ProcessSwarmingTaskResultPipeline.
|
| @@ -72,8 +72,9 @@ class SwarmingTasksToTryJobPipeline(BasePipeline):
|
| logging.info(logging_str)
|
| classified_tests_by_step.append(step_future)
|
|
|
| - # Waits until classified_tests_by_step are ready.
|
| + # Waits until classified_tests_by_step are ready.
|
| yield RunTryJobForReliableFailurePipeline(
|
| master_name, builder_name, build_number, good_revision,
|
| bad_revision, blame_list, try_job_type, compile_targets,
|
| - targeted_base_tests, suspected_cls, *classified_tests_by_step)
|
| + targeted_base_tests, suspected_cls, force_try_job,
|
| + *classified_tests_by_step)
|
|
|