buildbucket: add longest_pending_time API

appengine/cr-buildbucket/service.py

 # Copyright 2014 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.
 
 import contextlib
 import datetime
 import logging
 import urlparse
 
 from google.appengine.api import taskqueue
@@ skipping 815 matching lines @@
   if isinstance(identity, basestring):
     if not identity:  # pragma: no cover
       return None
     if ':' not in identity:  # pragma: no branch
       identity = 'user:%s' % identity
     try:
       identity = auth.Identity.from_bytes(identity)
     except ValueError as ex:
       raise errors.InvalidInputError('Invalid identity identity: %s' % ex)
   return identity
+
+
+def longest_pending_time(bucket, builder):
+  """Returns longest waiting time among SCHEDULED builds of a builder.
+
+  |builder| is a value of "builder" tag.
+
+  Returns a datetime.timedelta.
+  """
+  if not bucket:
+    raise errors.InvalidInputError('no bucket')
+  if not acl.can_access_bucket(bucket):
+    raise acl.current_identity_cannot('access bucket %s', bucket)
+  if not builder:
+    raise errors.InvalidInputError('no builder')
+
+  # Find the oldest, still SCHEDULED build in this builder.
+  q = model.Build.query(
+      model.Build.bucket == bucket,
+      model.Build.tags == ('builder:%s' % builder),
+      model.Build.status == model.BuildStatus.SCHEDULED,
+      projection=[model.Build.create_time])
+  q = q.order(model.Build.create_time)
+  result = q.fetch(1)
+  if not result:
+    return datetime.timedelta(0)
+  return utils.utcnow() - result[0].create_time