[Findit] Group failures by culprit and send notification to codereview.

appengine/findit/model/wf_culprit.py

Index: appengine/findit/model/wf_culprit.py
diff --git a/appengine/findit/model/wf_culprit.py b/appengine/findit/model/wf_culprit.py
new file mode 100644
index 0000000000000000000000000000000000000000..37099a25609b62532e1014cbefe67586bd722925
--- /dev/null
+++ b/appengine/findit/model/wf_culprit.py
@@ -0,0 +1,53 @@
+# 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.
+
+from google.appengine.ext import ndb
+
+from model import analysis_status as status
+
+
+class WfCulprit(ndb.Model):
+  """Represents a culprit that causes a group of failures on Chromium waterfall.
+
+  'Wf' is short for waterfall.
+  """
+
+  # Repo or project name of the culprit, eg: chromium, etc.
+  repo_name = ndb.StringProperty()
+
+  # The Git hash revision of the culprit.
+  revision = ndb.StringProperty(indexed=False)
+
+  # When the code-review of this culprit was notified.
+  cr_notification_time = ndb.DateTimeProperty()

[lijeffrey, 2016/06/21 17:59:54]

do we still want to do ndb.DateTimeProperty(indexed=True) to be able to query
for this later?

[stgao, 2016/06/24 16:10:28]

By default, it is indexed.
But I made it explicit.

+
+  # The status of code-review notification.
+  cr_notification_status = ndb.IntegerProperty()
+
+  # The list of builds in which the culprit caused some breakage.
+  builds = ndb.JsonProperty(indexed=False, default=[])
+
+  @property
+  def project_name(self):  # pragma: no cover
+    return self.repo_name
+
+  @property
+  def cr_notification_processed(self):
+    return self.cr_notification_status in (status.COMPLETED, status.RUNNING)
+
+  @property
+  def cr_notified(self):
+    return self.cr_notification_status == status.COMPLETED
+
+  @classmethod
+  def _CreateKey(cls, repo_name, revision):  # pragma: no cover
+    return ndb.Key(cls.__name__, '%s/%s' % (repo_name, revision))
+
+  @classmethod
+  def Create(cls, repo_name, revision):  # pragma: no cover
+    return cls(key=cls._CreateKey(repo_name, revision))
+
+  @classmethod
+  def Get(cls, repo_name, revision):  # pragma: no cover
+    return cls._CreateKey(repo_name, revision).get()