Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 10 additions & 6 deletions Lib/test/_test_multiprocessing.py
Original file line number Diff line number Diff line change
Expand Up @@ -340,6 +340,7 @@ def test_set_executable(self):
p.join()
self.assertEqual(p.exitcode, 0)

@unittest.skipIf(sys.platform == "linux", "TODO: RUSTPYTHON; flaky on CI")
@support.requires_resource('cpu')
def test_args_argument(self):
# bpo-45735: Using list or tuple as *args* in constructor could
Expand Down Expand Up @@ -445,6 +446,7 @@ def _test_report_parent_status(cls, wconn):
parent_process().join(timeout=support.SHORT_TIMEOUT)
wconn.send("alive" if parent_process().is_alive() else "not alive")

@unittest.skipIf(sys.platform == "linux", "TODO: RUSTPYTHON; flaky on CI")
def test_process(self):
q = self.Queue(1)
e = self.Event()
Expand Down Expand Up @@ -1394,6 +1396,7 @@ def _acquire_event(lock, event):
event.set()
time.sleep(1.0)

@unittest.skipIf(sys.platform == "linux", "TODO: RUSTPYTHON; flaky on CI")
def test_repr_lock(self):
if self.TYPE != 'processes':
self.skipTest('test not appropriate for {}'.format(self.TYPE))
Expand Down Expand Up @@ -2105,6 +2108,7 @@ def _test_wait_return_f(cls, barrier, queue):
res = barrier.wait()
queue.put(res)

@unittest.skipIf(sys.platform == "linux", "TODO: RUSTPYTHON; flaky on CI")
def test_wait_return(self):
"""
test the return value from barrier.wait
Expand Down Expand Up @@ -2972,8 +2976,7 @@ def test_map_no_failfast(self):
# check that we indeed waited for all jobs
self.assertGreater(time.monotonic() - t_start, 0.9)

# TODO: RUSTPYTHON - reference counting differences
@unittest.skip("TODO: RUSTPYTHON")
@unittest.skip("TODO: RUSTPYTHON; reference counting differences")
def test_release_task_refs(self):
# Issue #29861: task arguments and results should not be kept
# alive after we are done with them.
Expand Down Expand Up @@ -3303,6 +3306,7 @@ def _putter(cls, address, authkey):
queue = manager.get_queue()
queue.put('hello world')

@unittest.skipIf(sys.platform == "linux", "TODO: RUSTPYTHON; flaky on CI")
def test_rapid_restart(self):
authkey = os.urandom(32)
manager = QueueManager(
Expand Down Expand Up @@ -3886,8 +3890,7 @@ def _remote(cls, conn):

conn.close()

# TODO: RUSTPYTHON - hangs
@unittest.skip("TODO: RUSTPYTHON")
@unittest.skip("TODO: RUSTPYTHON; hangs")
def test_pickling(self):
families = self.connection.families

Expand Down Expand Up @@ -4463,6 +4466,7 @@ def test_shared_memory_SharedMemoryManager_reuses_resource_tracker(self):
# properly released sl.
self.assertFalse(err)

@unittest.skipIf(sys.platform == "linux", "TODO: RUSTPYTHON; flaky on CI")
def test_shared_memory_SharedMemoryManager_basics(self):
smm1 = multiprocessing.managers.SharedMemoryManager()
with self.assertRaises(ValueError):
Expand Down Expand Up @@ -4815,8 +4819,8 @@ def test_finalize(self):
result = [obj for obj in iter(conn.recv, 'STOP')]
self.assertEqual(result, ['a', 'b', 'd10', 'd03', 'd02', 'd01', 'e'])

# TODO: RUSTPYTHON - gc.get_threshold() and gc.set_threshold() not implemented
@unittest.expectedFailure
@unittest.skipIf(sys.platform == "linux", "TODO: RUSTPYTHON; flaky on CI")
@unittest.expectedFailure # TODO: RUSTPYTHON; gc.get_threshold() and gc.set_threshold() not implemented
@support.requires_resource('cpu')
def test_thread_safety(self):
# bpo-24484: _run_finalizers() should be thread-safe
Expand Down
Loading