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

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

Issue 2538373003: [Culprit-Finder] Merge lib/ to libs/. (Closed)
Patch Set: Rebase on https://codereview.chromium.org/2557553002/ Created 4 years 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 import textwrap 8 import textwrap
9 9
10 from common import appengine_util 10 from common import appengine_util
11 from common import constants 11 from common import constants
12 from common.pipeline_wrapper import BasePipeline 12 from common.pipeline_wrapper import BasePipeline
13 from lib import time_util 13 from libs import time_util
14 from model import analysis_status 14 from model import analysis_status
15 from model import result_status 15 from model import result_status
16 from model.flake.flake_swarming_task import FlakeSwarmingTask 16 from model.flake.flake_swarming_task import FlakeSwarmingTask
17 from model.flake.master_flake_analysis import MasterFlakeAnalysis 17 from model.flake.master_flake_analysis import MasterFlakeAnalysis
18 from waterfall import waterfall_config 18 from waterfall import waterfall_config
19 from waterfall.post_comment_to_bug_pipeline import PostCommentToBugPipeline 19 from waterfall.post_comment_to_bug_pipeline import PostCommentToBugPipeline
20 from waterfall.process_flake_swarming_task_result_pipeline import ( 20 from waterfall.process_flake_swarming_task_result_pipeline import (
21 ProcessFlakeSwarmingTaskResultPipeline) 21 ProcessFlakeSwarmingTaskResultPipeline)
22 from waterfall.trigger_flake_swarming_task_pipeline import ( 22 from waterfall.trigger_flake_swarming_task_pipeline import (
23 TriggerFlakeSwarmingTaskPipeline) 23 TriggerFlakeSwarmingTaskPipeline)
(...skipping 432 matching lines...) Expand 10 before | Expand all | Expand 10 after
456 master_flake_analysis, self.queue_name or constants.DEFAULT_QUEUE) 456 master_flake_analysis, self.queue_name or constants.DEFAULT_QUEUE)
457 return 457 return
458 458
459 pipeline_job = RecursiveFlakePipeline( 459 pipeline_job = RecursiveFlakePipeline(
460 master_name, builder_name, next_run, step_name, test_name, 460 master_name, builder_name, next_run, step_name, test_name,
461 version_number, master_build_number, 461 version_number, master_build_number,
462 flakiness_algorithm_results_dict=flakiness_algorithm_results_dict, 462 flakiness_algorithm_results_dict=flakiness_algorithm_results_dict,
463 manually_triggered=manually_triggered, 463 manually_triggered=manually_triggered,
464 use_nearby_neighbor=use_nearby_neighbor, 464 use_nearby_neighbor=use_nearby_neighbor,
465 step_size=(run_build_number - next_run)) 465 step_size=(run_build_number - next_run))
466 pipeline_job.target = appengine_util.GetTargetNameForModule( 466 pipeline_job.target = ( # pylint: disable=W
wrengr 2016/12/06 22:01:57 What warnings is this disabling?
Sharu Jiang 2016/12/07 00:13:15 defining target outside of __init__ of pipeline.
467 constants.WATERFALL_BACKEND) 467 appengine_util.GetTargetNameForModule(constants.WATERFALL_BACKEND))
468 pipeline_job.StartOffPSTPeakHours( 468 pipeline_job.StartOffPSTPeakHours(
469 queue_name=self.queue_name or constants.DEFAULT_QUEUE) 469 queue_name=self.queue_name or constants.DEFAULT_QUEUE)
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698