| Index: appengine/findit/waterfall/flake/recursive_flake_pipeline.py
|
| diff --git a/appengine/findit/waterfall/flake/recursive_flake_pipeline.py b/appengine/findit/waterfall/flake/recursive_flake_pipeline.py
|
| index 0541ed0399e33cd23a88a2210347777331e373fd..8ab76925b142e8c3ae5670cfd9be68192591d728 100644
|
| --- a/appengine/findit/waterfall/flake/recursive_flake_pipeline.py
|
| +++ b/appengine/findit/waterfall/flake/recursive_flake_pipeline.py
|
| @@ -10,7 +10,7 @@ import textwrap
|
| from common import appengine_util
|
| from common import constants
|
| from common.pipeline_wrapper import BasePipeline
|
| -from lib import time_util
|
| +from libs import time_util
|
| from model import analysis_status
|
| from model import result_status
|
| from model.flake.flake_swarming_task import FlakeSwarmingTask
|
| @@ -439,7 +439,7 @@ class NextBuildNumberPipeline(BasePipeline):
|
| manually_triggered=manually_triggered,
|
| use_nearby_neighbor=use_nearby_neighbor,
|
| step_size=(run_build_number - next_run))
|
| - pipeline_job.target = appengine_util.GetTargetNameForModule(
|
| - constants.WATERFALL_BACKEND)
|
| + pipeline_job.target = ( # pylint: disable=W
|
| + appengine_util.GetTargetNameForModule(constants.WATERFALL_BACKEND))
|
| pipeline_job.StartOffPSTPeakHours(
|
| queue_name=self.queue_name or constants.DEFAULT_QUEUE)
|
|
|