Waterfall components of regression range finder.

appengine/findit/waterfall/trigger_flake_swarming_task_pipeline.py

Index: appengine/findit/waterfall/trigger_flake_swarming_task_pipeline.py
diff --git a/appengine/findit/waterfall/trigger_flake_swarming_task_pipeline.py b/appengine/findit/waterfall/trigger_flake_swarming_task_pipeline.py
new file mode 100644
index 0000000000000000000000000000000000000000..9e8dd134306c4243a570099d5cbcbfb041ded403
--- /dev/null
+++ b/appengine/findit/waterfall/trigger_flake_swarming_task_pipeline.py
@@ -0,0 +1,39 @@
+from google.appengine.ext import ndb
+
+import logging
+
+from waterfall.trigger_base_swarming_task_pipeline import(
+    TriggerBaseSwarmingTaskPipeline)
+from model.flake.flake_swarming_task import FlakeSwarmingTask
+
+class TriggerFlakeSwarmingTaskPipeline(
+    TriggerBaseSwarmingTaskPipeline):
+  """A pipeline to check if selected tests of a step are flaky.
+
+  This pipeline only supports test steps that run on Swarming and support the
+  gtest filter.
+  """
+  #pylint: disable=arguments-differ
+  def _GetSwarmingTask(self,master_name, builder_name, build_number,
+                       step_name, test_name):
+    # Get the appropriate kind of Swarming Task (Flake).
+    swarming_task = FlakeSwarmingTask.Get(
+        master_name, builder_name, build_number, step_name, test_name)
+    return swarming_task
+
+  #pylint: disable=arguments-differ
+  def _CreateSwarmingTask(self, master_name, builder_name, build_number,
+                          step_name, test_name):
+    # Create the appropriate kind of Swarming Task (Flake).
+    swarming_task = FlakeSwarmingTask.Create(
+        master_name, builder_name, build_number, step_name, test_name)
+    return swarming_task
+
+  def _GetIterationsToRerun(self):
+    # How many times we want to run the swarming rerun?
+    # TODO(caiw): Move to config.
+    return 10

[lijeffrey, 2016/07/26 20:49:02]

this should already be in config. see waterfall_config.GetSwarmingSettings()

[caiw, 2016/07/26 21:09:01]

removed the todo.  Since the next cl won't use this method, this is also
basically just scaffolding.

+
+  def _GetArgs(self, master_name, builder_name, build_number, step_name, tests):
+    test_name = tests[0] #only one test per pipeline
+    return (master_name, builder_name, build_number, step_name, test_name)