Skip to content
This repository was archived by the owner on Jan 30, 2023. It is now read-only.

Commit 5a09cf1

Browse files
committed
Mark a few tests as known bug (#27537)
1 parent 0ad1dc1 commit 5a09cf1

File tree

1 file changed

+4
-19
lines changed

1 file changed

+4
-19
lines changed

src/sage/parallel/map_reduce.py

Lines changed: 4 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -1558,23 +1558,6 @@ def __init__(self, mapred, iproc, reduce_locally):
15581558
def _thief(self):
15591559
r"""
15601560
The thief thread of a worker process
1561-
1562-
EXAMPLES::
1563-
1564-
sage: from sage.parallel.map_reduce import RESetMPExample, RESetMapReduceWorker
1565-
sage: from threading import Thread
1566-
sage: EX = RESetMPExample(maxl=6)
1567-
sage: EX.setup_workers(2)
1568-
1569-
sage: w0, w1 = EX._workers
1570-
sage: w0._todo.append(42)
1571-
sage: thief0 = Thread(target = w0._thief, name="Thief")
1572-
sage: thief0.start()
1573-
1574-
sage: w1.steal()
1575-
42
1576-
sage: w0._todo
1577-
deque([])
15781561
"""
15791562
logger.debug("Thief started")
15801563
reqs = 0
@@ -1627,10 +1610,12 @@ def steal(self):
16271610
sage: w0, w1 = EX._workers
16281611
sage: w0._todo.append(42)
16291612
sage: thief0 = Thread(target = w0._thief, name="Thief")
1630-
sage: thief0.start()
1613+
sage: thief0.start() # known bug (Trac #27537)
16311614
1632-
sage: w1.steal()
1615+
sage: w1.steal() # known bug (Trac #27537)
16331616
42
1617+
sage: w0._todo # known bug (Trac #27537)
1618+
deque([])
16341619
"""
16351620
self._mapred._signal_task_done()
16361621
node = None

0 commit comments

Comments
 (0)