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

Side by Side Diff: appengine/findit/model/wf_swarming_task.py

Issue 2187763004: [Findit] Refactor Findit pipeline. (Closed) Base URL: https://chromium.googlesource.com/infra/infra.git@master
Patch Set: rebase Created 4 years, 4 months 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 collections import defaultdict 5 from collections import defaultdict
6 6
7 from google.appengine.ext import ndb 7 from google.appengine.ext import ndb
8 8
9 from model.base_build_model import BaseBuildModel 9 from model.base_build_model import BaseBuildModel
10 from model import analysis_status 10 from model import analysis_status
(...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after
57 elif test_statuses.get('UNKNOWN'): 57 elif test_statuses.get('UNKNOWN'):
58 classified_tests['unknown_tests'].append(test_name) 58 classified_tests['unknown_tests'].append(test_name)
59 else: 59 else:
60 # Here we consider a 'non-flaky' test to be 'reliable'. 60 # Here we consider a 'non-flaky' test to be 'reliable'.
61 # If the test is 'SKIPPED', there should be failure in its dependency, 61 # If the test is 'SKIPPED', there should be failure in its dependency,
62 # consider it to be failed as well. 62 # consider it to be failed as well.
63 # TODO(chanli): Check more test statuses. 63 # TODO(chanli): Check more test statuses.
64 classified_tests['reliable_tests'].append(test_name) 64 classified_tests['reliable_tests'].append(test_name)
65 return classified_tests 65 return classified_tests
66 66
67 @property
68 def reliable_tests(self):
69 return self.classified_tests.get('reliable_tests', [])
70
67 @staticmethod 71 @staticmethod
68 def _CreateKey( 72 def _CreateKey(
69 master_name, builder_name, build_number, step_name): # pragma: no cover 73 master_name, builder_name, build_number, step_name): # pragma: no cover
70 build_id = BaseBuildModel.CreateBuildId( 74 build_id = BaseBuildModel.CreateBuildId(
71 master_name, builder_name, build_number) 75 master_name, builder_name, build_number)
72 return ndb.Key('WfBuild', build_id, 'WfSwarmingTask', step_name) 76 return ndb.Key('WfBuild', build_id, 'WfSwarmingTask', step_name)
73 77
74 @staticmethod 78 @staticmethod
75 def Create( 79 def Create(
76 master_name, builder_name, build_number, step_name): # pragma: no cover 80 master_name, builder_name, build_number, step_name): # pragma: no cover
77 task = WfSwarmingTask( 81 task = WfSwarmingTask(
78 key=WfSwarmingTask._CreateKey( 82 key=WfSwarmingTask._CreateKey(
79 master_name, builder_name, build_number, step_name)) 83 master_name, builder_name, build_number, step_name))
80 task.parameters = task.parameters or {} 84 task.parameters = task.parameters or {}
81 task.tests_statuses = task.tests_statuses or {} 85 task.tests_statuses = task.tests_statuses or {}
82 return task 86 return task
83 87
84 @staticmethod 88 @staticmethod
85 def Get( 89 def Get(
86 master_name, builder_name, build_number, step_name): # pragma: no cover 90 master_name, builder_name, build_number, step_name): # pragma: no cover
87 return WfSwarmingTask._CreateKey( 91 return WfSwarmingTask._CreateKey(
88 master_name, builder_name, build_number, step_name).get() 92 master_name, builder_name, build_number, step_name).get()
OLDNEW
« no previous file with comments | « appengine/findit/model/test/wf_swarming_task_test.py ('k') | appengine/findit/waterfall/analyze_build_failure_pipeline.py » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698