[Findit] For automatic analyses of flaky tests, run the Swarming tasks off PST peak hours.

appengine/findit/waterfall/flake/initialize_flake_pipeline.py

Index: appengine/findit/waterfall/flake/initialize_flake_pipeline.py
diff --git a/appengine/findit/waterfall/flake/initialize_flake_pipeline.py b/appengine/findit/waterfall/flake/initialize_flake_pipeline.py
index 3c5d4351d8f56d4a82f394fe4e574a1e1949ebdb..ebfc7146dcf0b2f312cc8c50c0c70cde024aa8c6 100644
--- a/appengine/findit/waterfall/flake/initialize_flake_pipeline.py
+++ b/appengine/findit/waterfall/flake/initialize_flake_pipeline.py
@@ -55,6 +55,7 @@ def NeedANewAnalysis(
 # Unused arguments - pylint: disable=W0612, W0613
 def ScheduleAnalysisIfNeeded(master_name, builder_name, build_number, step_name,
                              test_name, allow_new_analysis=False, force=False,
+                             manually_triggered=False,
                              queue_name=constants.DEFAULT_QUEUE):
   """Schedules an analysis if needed and returns the MasterFlakeAnalysis.
 
@@ -69,6 +70,8 @@ def ScheduleAnalysisIfNeeded(master_name, builder_name, build_number, step_name,
     test_name (str): The single test we are checking
     allow_new_analysis (bool): Indicate whether a new analysis is allowed.
     force (bool): Indicate whether to force a rerun of current analysis.
+    manually_triggered (bool): True if the analysis is from manual request, like
+        by a Chromium sheriff.
     queue_name (str): The App Engine queue to run the analysis.
 
   Returns:
@@ -96,7 +99,8 @@ def ScheduleAnalysisIfNeeded(master_name, builder_name, build_number, step_name,
     pipeline_job = RecursiveFlakePipeline(
         master_name, builder_name, build_number, step_name, test_name,
         master_build_number=build_number,
-        flakiness_algorithm_results_dict=flakiness_algorithm_results_dict)
+        flakiness_algorithm_results_dict=flakiness_algorithm_results_dict,
+        manually_triggered=manually_triggered)
     pipeline_job.target = appengine_util.GetTargetNameForModule(
         constants.WATERFALL_BACKEND)
     pipeline_job.start(queue_name=queue_name)