Add function to trigger try jobs on Rietveld.

rietveld.py

 # coding: utf-8
 # Copyright (c) 2012 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.
 """Defines class Rietveld to easily access a rietveld instance.
 
 Security implications:
 
 The following hypothesis are made:
 - Rietveld enforces:
@@ skipping 282 matching lines @@
       if output.startswith('<'):
         # It's an error message. Return as no result.
         break
       data = json.loads(output) or {}
       if not data.get('results'):
         break
       for i in data['results']:
         yield i
       cursor = '&cursor=%s' % data['cursor']
 
+  def trigger_try_jobs(
+      self, issue, patchset, reason, clobber, revision, builders_and_tests):
+    """Requests new try jobs.
+
+    |builders_and_tests| is a map of builders: [tests] to run.
+
+    Returns the keys of the new TryJobResult entites.
+    """
+    params = [
+      ('reason', reason),
+      ('clobber', 'True' if clobber else 'False'),
+      ('revision', revision if revision else 'HEAD'),
+      ('builders', json.dumps(builders_and_tests)),
+      ('xsrf_token', self.xsrf_token()),
+    ]
+    return self.post('/%d/try/%d' % (issue, patchset), params)
+
+  def get_pending_try_jobs(self):

[Roger Tawa OOO till Jul 10th, 2012/09/04 13:40:12]

add docstring.

+    limit = 100
+    url = '/get_pending_try_patchsets?limit=%d' % limit
+    jobs = []
+    cursor = None

[Roger Tawa OOO till Jul 10th, 2012/09/04 13:40:12]

why not make |cursor| an argument to get_pending_try_jobs(), with a default
value of None?

+    while True:
+      extra = ('&cursor=' + cursor) if cursor else ''
+      data = json.loads(self.get(url + extra))
+      if not data['jobs']:
+        break
+      jobs.extend(data['jobs'])
+      cursor = data['cursor']
+    return jobs
+
   def get(self, request_path, **kwargs):
     kwargs.setdefault('payload', None)
     return self._send(request_path, **kwargs)
 
   def post(self, request_path, data, **kwargs):
     ctype, body = upload.EncodeMultipartFormData(data, [])
     return self._send(request_path, payload=body, content_type=ctype, **kwargs)
 
   def _send(self, request_path, **kwargs):
     """Sends a POST/GET to Rietveld.  Returns the response body."""
@@ skipping 29 matching lines @@
           if not 'Name or service not known' in e.reason:
             # Usually internal GAE flakiness.
             raise
         # If reaching this line, loop again. Uses a small backoff.
         time.sleep(1+maxtries*2)
     finally:
       upload.ErrorExit = old_error_exit
 
   # DEPRECATED.
   Send = get