Index: appengine/third_party/python-adb/adb/parallel.py |
diff --git a/appengine/third_party/python-adb/adb/parallel.py b/appengine/third_party/python-adb/adb/parallel.py |
index 4692600ac540afa8c65ac03a66e1da03d011c836..48d91f5046823f17a918baf77d622a50279a9d16 100644 |
--- a/appengine/third_party/python-adb/adb/parallel.py |
+++ b/appengine/third_party/python-adb/adb/parallel.py |
@@ -65,12 +65,16 @@ def _pmap(pool, queue_in, queue_out, fn, items): |
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 |