[Findit] Trigger swarming tasks after detech_first_faliure_pipeline

appengine/findit/waterfall/analyze_build_failure_pipeline.py

Index: appengine/findit/waterfall/analyze_build_failure_pipeline.py
diff --git a/appengine/findit/waterfall/analyze_build_failure_pipeline.py b/appengine/findit/waterfall/analyze_build_failure_pipeline.py
index 3d0717886e83fe6476040bc2bcd60d5cac7ba8cb..0bbf723556d6be3e0a7df2e4734eb3775ad3b3d3 100644
--- a/appengine/findit/waterfall/analyze_build_failure_pipeline.py
+++ b/appengine/findit/waterfall/analyze_build_failure_pipeline.py
@@ -15,6 +15,8 @@ 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):
@@ -67,6 +69,9 @@ class AnalyzeBuildFailurePipeline(BasePipeline):
     # 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)