mark failures

Lib/test/test_asyncio/test_free_threading.py

@@ -189,6 +189,14 @@ class TestPyFreeThreading(TestFreeThreading, TestCase):
     def factory(self, loop, coro, **kwargs):
         return asyncio.tasks._PyTask(coro, loop=loop, **kwargs)
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; AssertionError: <Task finished name='Task-7322' coro=<TestFreeThreading.test_task_different_thread_finalized.<locals>.func() done, defined at /Users/al03219714/Projects/RustPython2/crates/pylib/Lib/test/test_asyncio/test_free_threading.py:101> result=None> is not None
+    def test_task_different_thread_finalized(self):
+        return super().test_task_different_thread_finalized()
+
+    @unittest.skip("TODO: RUSTPYTHON; hangs - Python _current_tasks dict not thread-safe")
+    def test_all_tasks_race(self):
+        return super().test_all_tasks_race()
+
 
 @unittest.skipUnless(hasattr(asyncio.tasks, "_c_all_tasks"), "requires _asyncio")
 class TestCFreeThreading(TestFreeThreading, TestCase):
@@ -220,6 +228,14 @@ class TestEagerPyFreeThreading(TestPyFreeThreading):
     def factory(self, loop, coro, eager_start=True, **kwargs):
         return asyncio.tasks._PyTask(coro, loop=loop, **kwargs, eager_start=eager_start)
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; AssertionError: <Task finished name='Task-5240' coro=<TestFreeThreading.test_task_different_thread_finalized.<locals>.func() done, defined at /Users/al03219714/Projects/RustPython2/crates/pylib/Lib/test/test_asyncio/test_free_threading.py:101> result=None> is not None
+    def test_task_different_thread_finalized(self):
+        return super().test_task_different_thread_finalized()
+
+    @unittest.skip("TODO: RUSTPYTHON; hangs - Python _current_tasks dict not thread-safe")
+    def test_all_tasks_race(self):
+        return super().test_all_tasks_race()
+
 
 @unittest.skipUnless(hasattr(asyncio.tasks, "_c_all_tasks"), "requires _asyncio")
 class TestEagerCFreeThreading(TestCFreeThreading, TestCase):

Lib/test/test_asyncio/test_streams.py

@@ -1078,6 +1078,7 @@ class StreamTests(test_utils.TestCase):
 
         self.assertEqual(messages, [])
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; AssertionError: 0 != 1
     def test_unclosed_resource_warnings(self):
         async def inner(httpd):
             rd, wr = await asyncio.open_connection(*httpd.address)
@@ -1197,6 +1198,7 @@ class StreamTests(test_utils.TestCase):
         messages = self._basetest_unhandled_exceptions(handle_echo)
         self.assertEqual(messages, [])
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; NotImplementedError
     def test_open_connection_happy_eyeball_refcycles(self):
         port = socket_helper.find_unused_port()
         async def main():

Lib/test/test_asyncio/test_taskgroups.py

@@ -1106,6 +1106,30 @@ class BaseTestTaskGroup:
 class TestTaskGroup(BaseTestTaskGroup, unittest.IsolatedAsyncioTestCase):
     loop_factory = asyncio.EventLoop
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Test that TaskGroup deletes propagate_cancellation_error
+    async def test_exception_refcycles_propagate_cancellation_error(self):
+        return await super().test_exception_refcycles_propagate_cancellation_error()
+
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Test that TaskGroup deletes self._base_error
+    async def test_exception_refcycles_base_error(self):
+        return await super().test_exception_refcycles_base_error()
+
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Test that TaskGroup deletes self._errors, and __aexit__ args
+    async def test_exception_refcycles_errors(self):
+        return await super().test_exception_refcycles_errors()
+
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Test that TaskGroup deletes self._parent_task
+    async def test_exception_refcycles_parent_task(self):
+        return await super().test_exception_refcycles_parent_task()
+
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Test that TaskGroup deletes self._parent_task and create_task() deletes task
+    async def test_exception_refcycles_parent_task_wr(self):
+        return await super().test_exception_refcycles_parent_task_wr()
+
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Test that TaskGroup doesn't keep a reference to the raised ExceptionGroup
+    async def test_exception_refcycles_direct(self):
+        return await super().test_exception_refcycles_direct()
+
 class TestEagerTaskTaskGroup(BaseTestTaskGroup, unittest.IsolatedAsyncioTestCase):
     @staticmethod
     def loop_factory():
@@ -1113,6 +1137,30 @@ class TestEagerTaskTaskGroup(BaseTestTaskGroup, unittest.IsolatedAsyncioTestCase
         loop.set_task_factory(asyncio.eager_task_factory)
         return loop
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Test that TaskGroup deletes propagate_cancellation_error
+    async def test_exception_refcycles_propagate_cancellation_error(self):
+        return await super().test_exception_refcycles_propagate_cancellation_error()
+
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Test that TaskGroup deletes self._base_error
+    async def test_exception_refcycles_base_error(self):
+        return await super().test_exception_refcycles_base_error()
+
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Test that TaskGroup deletes self._errors, and __aexit__ args
+    async def test_exception_refcycles_errors(self):
+        return await super().test_exception_refcycles_errors()
+
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Test that TaskGroup deletes self._parent_task
+    async def test_exception_refcycles_parent_task(self):
+        return await super().test_exception_refcycles_parent_task()
+
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Test that TaskGroup deletes self._parent_task and create_task() deletes task
+    async def test_exception_refcycles_parent_task_wr(self):
+        return await super().test_exception_refcycles_parent_task_wr()
+
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Test that TaskGroup doesn't keep a reference to the raised ExceptionGroup
+    async def test_exception_refcycles_direct(self):
+        return await super().test_exception_refcycles_direct()
+
 
 if __name__ == "__main__":
     unittest.main()

Lib/test/test_asyncio/test_tasks.py

@@ -2942,6 +2942,10 @@ class CTask_CFuture_Tests(BaseTaskTests, SetMethodsTest,
         with self.assertRaises(AttributeError):
             del task._log_destroy_pending
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Actual: not called.
+    def test_log_destroyed_pending_task(self):
+        return super().test_log_destroyed_pending_task()
+
 
 @unittest.skipUnless(hasattr(futures, '_CFuture') and
                      hasattr(tasks, '_CTask'),
@@ -2954,6 +2958,10 @@ class CTask_CFuture_SubclassTests(BaseTaskTests, test_utils.TestCase):
     all_tasks = getattr(tasks, '_c_all_tasks', None)
     current_task = staticmethod(getattr(tasks, '_c_current_task', None))
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Actual: not called.
+    def test_log_destroyed_pending_task(self):
+        return super().test_log_destroyed_pending_task()
+
 
 @unittest.skipUnless(hasattr(tasks, '_CTask'),
                      'requires the C _asyncio module')
@@ -2965,6 +2973,10 @@ class CTaskSubclass_PyFuture_Tests(BaseTaskTests, test_utils.TestCase):
     all_tasks = getattr(tasks, '_c_all_tasks', None)
     current_task = staticmethod(getattr(tasks, '_c_current_task', None))
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Actual: not called.
+    def test_log_destroyed_pending_task(self):
+        return super().test_log_destroyed_pending_task()
+
 
 @unittest.skipUnless(hasattr(futures, '_CFuture'),
                      'requires the C _asyncio module')
@@ -2976,6 +2988,10 @@ class PyTask_CFutureSubclass_Tests(BaseTaskTests, test_utils.TestCase):
     all_tasks = staticmethod(tasks._py_all_tasks)
     current_task = staticmethod(tasks._py_current_task)
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Actual: not called.
+    def test_log_destroyed_pending_task(self):
+        return super().test_log_destroyed_pending_task()
+
 
 @unittest.skipUnless(hasattr(tasks, '_CTask'),
                      'requires the C _asyncio module')
@@ -2986,6 +3002,10 @@ class CTask_PyFuture_Tests(BaseTaskTests, test_utils.TestCase):
     all_tasks = getattr(tasks, '_c_all_tasks', None)
     current_task = staticmethod(getattr(tasks, '_c_current_task', None))
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Actual: not called.
+    def test_log_destroyed_pending_task(self):
+        return super().test_log_destroyed_pending_task()
+
 
 @unittest.skipUnless(hasattr(futures, '_CFuture'),
                      'requires the C _asyncio module')
@@ -2996,6 +3016,10 @@ class PyTask_CFuture_Tests(BaseTaskTests, test_utils.TestCase):
     all_tasks = staticmethod(tasks._py_all_tasks)
     current_task = staticmethod(tasks._py_current_task)
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Actual: not called.
+    def test_log_destroyed_pending_task(self):
+        return super().test_log_destroyed_pending_task()
+
 
 class PyTask_PyFuture_Tests(BaseTaskTests, SetMethodsTest,
                             test_utils.TestCase):
@@ -3005,6 +3029,10 @@ class PyTask_PyFuture_Tests(BaseTaskTests, SetMethodsTest,
     all_tasks = staticmethod(tasks._py_all_tasks)
     current_task = staticmethod(tasks._py_current_task)
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Actual: not called.
+    def test_log_destroyed_pending_task(self):
+        return super().test_log_destroyed_pending_task()
+
 
 @add_subclass_tests
 class PyTask_PyFuture_SubclassTests(BaseTaskTests, test_utils.TestCase):
@@ -3013,6 +3041,10 @@ class PyTask_PyFuture_SubclassTests(BaseTaskTests, test_utils.TestCase):
     all_tasks = staticmethod(tasks._py_all_tasks)
     current_task = staticmethod(tasks._py_current_task)
 
+    @unittest.expectedFailure  # TODO: RUSTPYTHON; Actual: not called.
+    def test_log_destroyed_pending_task(self):
+        return super().test_log_destroyed_pending_task()
+
 @unittest.skipUnless(hasattr(tasks, '_CTask'),
                      'requires the C _asyncio module')
 class CTask_Future_Tests(test_utils.TestCase):