[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 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 32 matching lines @@
   # Arguments number differs from overridden method - pylint: disable=W0221
   def run(self, master_name, builder_name, build_number, build_completed,
           force_rerun_try_job):
     self._ResetAnalysis(master_name, builder_name, build_number)
 
     # 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)
+    # Trigger swarming tasks when test failure happens.
+    yield TriggerSwarmingTasksPipeline(
+        master_name, builder_name, build_number, failure_info)
     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(

[stgao, 2016/07/12 17:47:49]

As discussed, TriggerSwarmingTasksPipeline and StartTryJobOnDemandPipeline
should be run in order to make sure Swarming are triggered before we start
waiting.

We could use InOrder or After. InOrder is preferred, as we might add another
subpipeline in this ordered processing.

[chanli, 2016/07/12 20:04:52]

Done.

         failure_info, signals, build_completed, force_rerun_try_job,
         heuristic_result)