[Findit] Adding logic to force try jobs regardless of bailout or previous results

appengine/findit/waterfall/test/build_failure_analysis_pipelines_test.py

 # Copyright 2014 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 import logging
 
 from testing_utils import testing
 
 from common import constants
 from common.pipeline_wrapper import pipeline_handlers
 from model import analysis_status
 from model.wf_analysis import WfAnalysis
 from waterfall import build_failure_analysis_pipelines
 
 
 class _MockRootPipeline(object):
   STARTED = False
 
-  def __init__(self, master_name, builder_name, build_number, build_completed):
+  def __init__(self, master_name, builder_name, build_number, build_completed,
+               force_try_job):
     pass
 
   def pipeline_status_path(self):
     return ''
 
   def start(self, queue_name):
     _MockRootPipeline.STARTED = True
     logging.info(queue_name)
 
 
@@ skipping 129 matching lines @@
     builder_name = 'b'
     build_number = 124
 
     self.mock(build_failure_analysis_pipelines.analyze_build_failure_pipeline,
               'AnalyzeBuildFailurePipeline',
               _MockRootPipeline)
     _MockRootPipeline.STARTED = False
 
     build_failure_analysis_pipelines.ScheduleAnalysisIfNeeded(
         master_name, builder_name, build_number, failed_steps=['a'],
-        build_completed=False, force=False, queue_name=constants.DEFAULT_QUEUE)
+        build_completed=False, force=False, force_try_job=False,
+        queue_name=constants.DEFAULT_QUEUE)
 
     analysis = WfAnalysis.Get(master_name, builder_name, build_number)
 
     self.assertTrue(_MockRootPipeline.STARTED)
     self.assertIsNotNone(analysis)
 
   def testNotStartPipelineForNewAnalysis(self):
     master_name = 'm'
     builder_name = 'b'
     build_number = 123
     not_passed_steps = ['a']
 
     self._CreateAndSaveWfAnalysis(
         master_name, builder_name, build_number,
         not_passed_steps, analysis_status.RUNNING)
 
     self.mock(build_failure_analysis_pipelines.analyze_build_failure_pipeline,
               'AnalyzeBuildFailurePipeline',
               _MockRootPipeline)
     _MockRootPipeline.STARTED = False
 
     build_failure_analysis_pipelines.ScheduleAnalysisIfNeeded(
         master_name, builder_name, build_number, failed_steps=['a'],
         build_completed=True, force=False, queue_name=constants.DEFAULT_QUEUE)
 
     self.assertFalse(_MockRootPipeline.STARTED)