multiarchimport.py: log exceptions from worker processes

1 files changed, 4 insertions, 1 deletions

diff --git a/multiarchimport.py b/multiarchimport.py
index af9d1c1..7271410 100755
--- a/multiarchimport.py
+++ b/multiarchimport.py
@@ -151,10 +151,13 @@ def bounded_imap_unordered(bound, pool, function, iterable):
     iterable = iter(iterable)
     results = queue.Queue()
     outstanding = 0
+    def error_callback(exception):
+        logging.exception("worker exception", exc_info=exception)
     while iterable or outstanding:
         if iterable:
             for elem in iterable:
-                pool.apply_async(function, (elem,), callback=results.put)
+                pool.apply_async(function, (elem,), callback=results.put,
+                                 error_callback=error_callback)
                 outstanding += 1
                 if outstanding >= bound or not results.empty():
                     break