[Findit] Trigger swarming tasks after detech_first_faliure_pipeline

appengine/findit/waterfall/analyze_build_failure_pipeline.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 common import appengine_util
 from common.pipeline_wrapper import BasePipeline
+from common.pipeline_wrapper import pipeline
 from model import analysis_status
 from model.wf_analysis import WfAnalysis
 from waterfall.detect_first_failure_pipeline import DetectFirstFailurePipeline
 from waterfall.extract_deps_info_pipeline import ExtractDEPSInfoPipeline
 from waterfall.extract_signal_pipeline import ExtractSignalPipeline
 from waterfall.identify_culprit_pipeline import IdentifyCulpritPipeline
 from waterfall.pull_changelog_pipeline import PullChangelogPipeline
 from waterfall.start_try_job_on_demand_pipeline import (
     StartTryJobOnDemandPipeline)
+from waterfall.trigger_swarming_tasks_pipeline import (
+    TriggerSwarmingTasksPipeline)
 
 
 class AnalyzeBuildFailurePipeline(BasePipeline):
 
   def __init__(self, master_name, builder_name, build_number, build_completed,
                force_rerun_try_job):
     super(AnalyzeBuildFailurePipeline, self).__init__(
         master_name, builder_name, build_number, build_completed,
         force_rerun_try_job)
     self.master_name = master_name
@@ skipping 37 matching lines @@
     # The yield statements below return PipelineFutures, which allow subsequent
     # pipelines to refer to previous output values.
     # https://github.com/GoogleCloudPlatform/appengine-pipelines/wiki/Python
     failure_info = yield DetectFirstFailurePipeline(
         master_name, builder_name, build_number)
     change_logs = yield PullChangelogPipeline(failure_info)
     deps_info = yield ExtractDEPSInfoPipeline(failure_info, change_logs)
     signals = yield ExtractSignalPipeline(failure_info)
     heuristic_result = yield IdentifyCulpritPipeline(
         failure_info, change_logs, deps_info, signals, build_completed)
-    yield StartTryJobOnDemandPipeline(
-        failure_info, signals, build_completed, force_rerun_try_job,
-        heuristic_result)
+
+    with pipeline.InOrder():
+      # Trigger swarming tasks when test failure happens.
+      yield TriggerSwarmingTasksPipeline(
+          master_name, builder_name, build_number, failure_info)
+      yield StartTryJobOnDemandPipeline(

[stgao, 2016/07/12 20:26:52]

nit: maybe add a comment here too.

[chanli, 2016/07/12 20:41:19]

Done.

+          failure_info, signals, build_completed, force_rerun_try_job,
+          heuristic_result)