[debugging via CI] Temporarily raise with the queue IDs.

Author: ericsnowcurrently

Lib/test/test_concurrent_futures/test_interpreter_pool.py

@@ -358,6 +358,7 @@ def test_blocking(self):
         blocker = queues.create()
 
         def run(ready, blocker):
+            raise Exception((ready.id, blocker.id))
             ready.put(None)
             blocker.get()  # blocking
 
@@ -369,9 +370,15 @@ def run(ready, blocker):
                 fut = executor.submit(run, ready, blocker)
                 futures.append(fut)
             assert len(executor._threads) == numtasks, len(executor._threads)
-            # Unblock the workers.
-            for i in range(numtasks):
-                blocker.put_nowait(None)
+            ctx = None
+            for i, fut in enumerate(futures, 1):
+                try:
+                    fut.result(timeout=10)
+                except Exception as exc:
+                    exc.__cause__ = ctx
+                    ctx = exc
+                    if i == numtasks:
+                        raise Exception((ready.id, blocker.id))
 #            try:
 #                # Wait for them all to be ready.
 #                for i in range(numtasks):