[Findit] Trigger swarming tasks after detech_first_faliure_pipeline

appengine/findit/waterfall/test/try_job_util_test.py

 # Copyright 2015 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.
 
 from datetime import datetime
 from datetime import timedelta
 
 from common.waterfall import failure_type
 from model import analysis_status
 from model.wf_build import WfBuild
@@ skipping 350 matching lines @@
   def testNeedANewTryJobIfTestFailureSwarming(self):
     master_name = 'm'
     builder_name = 'b'
     build_number = 223
     failed_steps = {
         'a': {
             'current_failure': 223,
             'first_failure': 222,
             'last_pass': 221,
             'tests': {
-                'a.t1': {
+                'a.PRE_t1': {
                     'current_failure': 223,
                     'first_failure': 223,
-                    'last_pass': 221
+                    'last_pass': 221,
+                    'base_test_name': 'a.t1'
                 },
                 'a.t2': {
                     'current_failure': 223,
                     'first_failure': 222,
                     'last_pass': 221
                 },
                 'a.t3': {
                     'current_failure': 223,
                     'first_failure': 223,
                     'last_pass': 222
@@ skipping 19 matching lines @@
         }
     }
 
     failure_result_map = {}
     need_try_job, last_pass, try_job_type, targeted_tests = (
         try_job_util._NeedANewTryJob(master_name, builder_name, build_number,
                                      failed_steps, failure_result_map))
 
     expected_failure_result_map = {
         'a': {
-            'a.t1': 'm/b/223',
+            'a.PRE_t1': 'm/b/223',
             'a.t2': 'm/b/222',
             'a.t3': 'm/b/223'
         },
         'b': {
             'b.t1': 'm/b/222',
             'b.t2': 'm/b/222'
         },
     }
 
     expected_targeted_tests = {
@@ skipping 156 matching lines @@
         try_job_util._GetSuspectsFromHeuristicResult(heuristic_result))
 
   def testShouldBailOutforOutdatedBuild(self):
     yesterday = datetime.utcnow() - timedelta(days=1)
     build = WfBuild.Create('m', 'b', 1)
     build.start_time = yesterday
     self.assertTrue(try_job_util._ShouldBailOutForOutdatedBuild(build))
 
     build.start_time = yesterday + timedelta(hours=1)
     self.assertFalse(try_job_util._ShouldBailOutForOutdatedBuild(build))