Chromium Code Reviews| 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 |