Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(66)

Side by Side Diff: appengine/findit/waterfall/flake/recursive_flake_pipeline.py

Issue 2480593002: [Predator] Move time_util from common/ to lib/, split code review related part to code_review_util (Closed)
Patch Set: Rebase and fix nits. Created 4 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 # Copyright 2016 The Chromium Authors. All rights reserved. 1 # Copyright 2016 The Chromium Authors. All rights reserved.
2 # Use of this source code is governed by a BSD-style license that can be 2 # Use of this source code is governed by a BSD-style license that can be
3 # found in the LICENSE file. 3 # found in the LICENSE file.
4 4
5 from datetime import timedelta 5 from datetime import timedelta
6 import logging 6 import logging
7 import random 7 import random
8 8
9 from common import appengine_util 9 from common import appengine_util
10 from common import constants 10 from common import constants
11 from common import time_util
12 from common.pipeline_wrapper import BasePipeline 11 from common.pipeline_wrapper import BasePipeline
13 12 from lib import time_util
14 from model import analysis_status 13 from model import analysis_status
15 from model import result_status 14 from model import result_status
16 from model.flake.flake_swarming_task import FlakeSwarmingTask 15 from model.flake.flake_swarming_task import FlakeSwarmingTask
17 from model.flake.master_flake_analysis import MasterFlakeAnalysis 16 from model.flake.master_flake_analysis import MasterFlakeAnalysis
18 from waterfall import waterfall_config 17 from waterfall import waterfall_config
19 from waterfall.process_flake_swarming_task_result_pipeline import ( 18 from waterfall.process_flake_swarming_task_result_pipeline import (
20 ProcessFlakeSwarmingTaskResultPipeline) 19 ProcessFlakeSwarmingTaskResultPipeline)
21 from waterfall.trigger_flake_swarming_task_pipeline import ( 20 from waterfall.trigger_flake_swarming_task_pipeline import (
22 TriggerFlakeSwarmingTaskPipeline) 21 TriggerFlakeSwarmingTaskPipeline)
23 22
(...skipping 254 matching lines...) Expand 10 before | Expand all | Expand 10 after
278 flakiness_algorithm_results_dict=flakiness_algorithm_results_dict, 277 flakiness_algorithm_results_dict=flakiness_algorithm_results_dict,
279 manually_triggered=manually_triggered) 278 manually_triggered=manually_triggered)
280 # pylint: disable=W0201 279 # pylint: disable=W0201
281 pipeline_job.target = appengine_util.GetTargetNameForModule( 280 pipeline_job.target = appengine_util.GetTargetNameForModule(
282 constants.WATERFALL_BACKEND) 281 constants.WATERFALL_BACKEND)
283 pipeline_job.StartOffPSTPeakHours( 282 pipeline_job.StartOffPSTPeakHours(
284 queue_name=self.queue_name or constants.DEFAULT_QUEUE) 283 queue_name=self.queue_name or constants.DEFAULT_QUEUE)
285 else: 284 else:
286 _UpdateAnalysisStatusUponCompletion( 285 _UpdateAnalysisStatusUponCompletion(
287 master_flake_analysis, analysis_status.COMPLETED, None) 286 master_flake_analysis, analysis_status.COMPLETED, None)
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698