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

appengine/findit/waterfall/flake/initialize_flake_pipeline.py

 # Copyright 2016 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.
 
 import logging
 
 from common import appengine_util
 from common import constants
 from common import time_util
 from model import analysis_status
@@ skipping 35 matching lines @@
   else:
     # The previous analysis had some error, so reset and run as a new version.
     master_flake_analysis.Reset()
     _, saved = master_flake_analysis.Save()
     return saved
 
 
 # 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.
 
   When the build failure was already analyzed and a new analysis is scheduled,
   the returned WfAnalysis will still have the result of last completed analysis.
 
   Args:
     master_name (str): The master name of the failed test
     builder_name (str): The builder name of the failed test
     build_number (int): The build number of the failed test
     step_name (str): The name of the test suite
     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:
     A MasterFlakeAnalysis instance.
     None if no analysis was scheduled and the user has no permission to.
   """
 
   version_number = None
 
   if NeedANewAnalysis(
@@ skipping 28 matching lines @@
             0, build_number - max_build_numbers_to_look_back),
         'lower_boundary': None,
         'upper_boundary': None,
         'lower_boundary_result': None,
         'sequential_run_index': 0
     }
 
     pipeline_job = RecursiveFlakePipeline(
         master_name, builder_name, build_number, step_name, test_name,
         version_number, 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)
+    pipeline_job.StartOffPSTPeakHours(queue_name=queue_name)
   return MasterFlakeAnalysis.GetVersion(
       master_name, builder_name, build_number, step_name, test_name,
       version=version_number)