Small fixes as found in staging.

appengine/third_party/python-adb/adb/parallel.py

 # Copyright 2015 Google Inc. All rights reserved.
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
 # You may obtain a copy of the License at
 #
 #     http://www.apache.org/licenses/LICENSE-2.0
 #
 # Unless required by applicable law or agreed to in writing, software
 # distributed under the License is distributed on an "AS IS" BASIS,
@@ skipping 47 matching lines @@
   while len(pool) < len(items) and len(pool) < 64:
     t = threading.Thread(
         target=_run, name='parallel%d' % len(pool), args=(queue_in, queue_out))
     t.daemon = True
     t.start()
     pool.append(t)
 
   for index, item in enumerate(items):
     queue_in.put((index, fn, item))
   out = [None] * len(items)
+  e = None
   for _ in xrange(len(items)):
     index, result = queue_out.get()
     if index < 0:
       # This is an exception.
-      raise result[0], result[1], result[2]
-    out[index] = result
+      e = result

[ghost stip (do not use), 2015/11/03 18:50:47]

and I guess we'll just clobber repeated errors

[M-A Ruel, 2015/11/04 18:39:10]

yes

+    else:
+      out[index] = result
+  if e:
+    raise e[0], e[1], e[2]
   return out
 
 
 def _run(queue_in, queue_out):
   while True:
     index, fn, item = queue_in.get()
     try:
       result = fn(item)
     except:  # pylint: disable=bare-except
       # Starts at -1 otherwise -0 == 0.
       index = -index - 1
       result = sys.exc_info()
     finally:
       queue_out.put((index, result))