| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent f3cc1a5 commit fe90bee
8 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -1501,7 +1501,7 @@ def test_create_connection_no_inet_pton(self, m_socket): | |||
| 1501 | 1501 | support.is_android and platform.android_ver().api_level < 23, | |
| 1502 | 1502 | "Issue gh-71123: this fails on Android before API level 23" | |
| 1503 | 1503 | ) | |
| 1504 | - @unittest.skip('TODO: RUSTPYTHON; TypeError: unexpected type bytes') | ||
| 1504 | + @unittest.expectedFailure # TODO: RUSTPYTHON; TypeError: unexpected type bytes | ||
| 1505 | 1505 | def test_create_connection_service_name(self, m_socket): | |
| 1506 | 1506 | m_socket.getaddrinfo = socket.getaddrinfo | |
| 1507 | 1507 | sock = m_socket.socket.return_value | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -269,7 +269,7 @@ class PyEagerTaskFactoryLoopTests(EagerTaskFactoryLoopTests, test_utils.TestCase | |||
| 269 | 269 | Task = tasks._PyTask | |
| 270 | 270 | ||
| 271 | 271 | ||
| 272 | - @unittest.skip('TODO: RUSTPYTHON: CPython specific test') | ||
| 272 | + # TODO: RUSTPYTHON: CPython specific test | ||
| 273 | 273 | @unittest.skipUnless(hasattr(tasks, '_CTask'), | |
| 274 | 274 | 'requires the C _asyncio module') | |
| 275 | 275 | class CEagerTaskFactoryLoopTests(EagerTaskFactoryLoopTests, test_utils.TestCase): | |
@@ -416,13 +416,13 @@ class NonEagerPyTaskTests(BaseNonEagerTaskFactoryTests, test_utils.TestCase): | |||
| 416 | 416 | class EagerPyTaskTests(BaseEagerTaskFactoryTests, test_utils.TestCase): | |
| 417 | 417 | Task = tasks._PyTask | |
| 418 | 418 | ||
| 419 | - @unittest.skip('TODO: RUSTPYTHON: CPython specific test') | ||
| 419 | + # TODO: RUSTPYTHON: CPython specific test | ||
| 420 | 420 | @unittest.skipUnless(hasattr(tasks, '_CTask'), | |
| 421 | 421 | 'requires the C _asyncio module') | |
| 422 | 422 | class NonEagerCTaskTests(BaseNonEagerTaskFactoryTests, test_utils.TestCase): | |
| 423 | 423 | Task = getattr(tasks, '_CTask', None) | |
| 424 | 424 | ||
| 425 | - @unittest.skip('TODO: RUSTPYTHON: CPython specific test') | ||
| 425 | + # TODO: RUSTPYTHON: CPython specific test | ||
| 426 | 426 | @unittest.skipUnless(hasattr(tasks, '_CTask'), | |
| 427 | 427 | 'requires the C _asyncio module') | |
| 428 | 428 | class EagerCTaskTests(BaseEagerTaskFactoryTests, test_utils.TestCase): | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -444,8 +444,8 @@ def writer(data): | |||
| 444 | 444 | r.close() | |
| 445 | 445 | self.assertEqual(read, data) | |
| 446 | 446 | ||
| 447 | + @unittest.expectedFailure # TODO: RUSTPYTHON; OSError: Failed to set signal | ||
| 447 | 448 | @unittest.skipUnless(hasattr(signal, 'SIGKILL'), 'No SIGKILL') | |
| 448 | - @unittest.skip('TODO: RUSTPYTHON; OSError: Failed to set signal') | ||
| 449 | 449 | def test_add_signal_handler(self): | |
| 450 | 450 | caught = 0 | |
| 451 | 451 | ||
@@ -1172,8 +1172,8 @@ def test_create_unix_server_ssl_verified(self): | |||
| 1172 | 1172 | server.close() | |
| 1173 | 1173 | self.loop.run_until_complete(proto.done) | |
| 1174 | 1174 | ||
| 1175 | - @unittest.skipIf(ssl is None, 'No ssl module') | ||
| 1176 | 1175 | @unittest.expectedFailure # TODO: RUSTPYTHON AssertionError: {'OCSP': ('http://testca.pythontest.net/tes[629 chars]': 3} != {'subject': ((('countryName', ''),), (('loc[419 chars]'),)} | |
| 1176 | + @unittest.skipIf(ssl is None, 'No ssl module') | ||
| 1177 | 1177 | def test_create_server_ssl_verified(self): | |
| 1178 | 1178 | proto = MyProto(loop=self.loop) | |
| 1179 | 1179 | server, host, port = self._make_ssl_server( | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -678,7 +678,7 @@ def __del__(self): | |||
| 678 | 678 | fut = self._new_future(loop=self.loop) | |
| 679 | 679 | fut.set_result(Evil()) | |
| 680 | 680 | ||
| 681 | - @unittest.skip('TODO: RUSTPYTHON; NotImplementedError') | ||
| 681 | + @unittest.expectedFailure # TODO: RUSTPYTHON; NotImplementedError | ||
| 682 | 682 | def test_future_cancelled_result_refcycles(self): | |
| 683 | 683 | f = self._new_future(loop=self.loop) | |
| 684 | 684 | f.cancel() | |
@@ -690,7 +690,7 @@ def test_future_cancelled_result_refcycles(self): | |||
| 690 | 690 | self.assertIsNotNone(exc) | |
| 691 | 691 | self.assertListEqual(gc.get_referrers(exc), []) | |
| 692 | 692 | ||
| 693 | - @unittest.skip('TODO: RUSTPYTHON; NotImplementedError') | ||
| 693 | + @unittest.expectedFailure # TODO: RUSTPYTHON; NotImplementedError | ||
| 694 | 694 | def test_future_cancelled_exception_refcycles(self): | |
| 695 | 695 | f = self._new_future(loop=self.loop) | |
| 696 | 696 | f.cancel() | |
@@ -702,7 +702,7 @@ def test_future_cancelled_exception_refcycles(self): | |||
| 702 | 702 | self.assertIsNotNone(exc) | |
| 703 | 703 | self.assertListEqual(gc.get_referrers(exc), []) | |
| 704 | 704 | ||
| 705 | - @unittest.skip('TODO: RUSTPYTHON: CPython specific test') | ||
| 705 | + # TODO: RUSTPYTHON: CPython specific test | ||
| 706 | 706 | @unittest.skipUnless(hasattr(futures, '_CFuture'), | |
| 707 | 707 | 'requires the C _asyncio module') | |
| 708 | 708 | class CFutureTests(BaseFutureTests, test_utils.TestCase): | |
@@ -744,7 +744,7 @@ def test_callbacks_copy(self): | |||
| 744 | 744 | fut.remove_done_callback(f2) | |
| 745 | 745 | self.assertIsNone(fut._callbacks) | |
| 746 | 746 | ||
| 747 | - @unittest.skip('TODO: RUSTPYTHON: CPython specific test') | ||
| 747 | + # TODO: RUSTPYTHON: CPython specific test | ||
| 748 | 748 | @unittest.skipUnless(hasattr(futures, '_CFuture'), | |
| 749 | 749 | 'requires the C _asyncio module') | |
| 750 | 750 | class CSubFutureTests(BaseFutureTests, test_utils.TestCase): | |
@@ -1077,7 +1077,7 @@ def __getattribute__(self, name): | |||
| 1077 | 1077 | del fut_callback_0 | |
| 1078 | 1078 | self.assertRaises(ReachableCode, fut.set_result, "boom") | |
| 1079 | 1079 | ||
| 1080 | - @unittest.skip('TODO: RUSTPYTHON: CPython specific test') | ||
| 1080 | + # TODO: RUSTPYTHON: CPython specific test | ||
| 1081 | 1081 | @unittest.skipUnless(hasattr(futures, '_CFuture'), | |
| 1082 | 1082 | 'requires the C _asyncio module') | |
| 1083 | 1083 | class CFutureDoneCallbackTests(BaseFutureDoneCallbackTests, | |
@@ -1086,7 +1086,7 @@ class CFutureDoneCallbackTests(BaseFutureDoneCallbackTests, | |||
| 1086 | 1086 | def _new_future(self): | |
| 1087 | 1087 | return futures._CFuture(loop=self.loop) | |
| 1088 | 1088 | ||
| 1089 | - @unittest.skip('TODO: RUSTPYTHON: CPython specific test') | ||
| 1089 | + # TODO: RUSTPYTHON: CPython specific test | ||
| 1090 | 1090 | @unittest.skipUnless(hasattr(futures, '_CFuture'), | |
| 1091 | 1091 | 'requires the C _asyncio module') | |
| 1092 | 1092 | class CSubFutureDoneCallbackTests(BaseFutureDoneCallbackTests, | |
@@ -1137,7 +1137,7 @@ class PyFutureInheritanceTests(BaseFutureInheritanceTests, | |||
| 1137 | 1137 | def _get_future_cls(self): | |
| 1138 | 1138 | return futures._PyFuture | |
| 1139 | 1139 | ||
| 1140 | - @unittest.skip('TODO: RUSTPYTHON: CPython specific test') | ||
| 1140 | + # TODO: RUSTPYTHON: CPython specific test | ||
| 1141 | 1141 | @unittest.skipUnless(hasattr(futures, '_CFuture'), | |
| 1142 | 1142 | 'requires the C _asyncio module') | |
| 1143 | 1143 | class CFutureInheritanceTests(BaseFutureInheritanceTests, | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -680,7 +680,7 @@ async def client(addr): | |||
| 680 | 680 | ||
| 681 | 681 | self.assertEqual(res, 'OK') | |
| 682 | 682 | ||
| 683 | - @unittest.skip('TODO: RUSTPYTHON; RuntimeError: Event loop stopped before Future completed.') | ||
| 683 | + @unittest.expectedFailure # TODO: RUSTPYTHON; RuntimeError: Event loop stopped before Future completed. | ||
| 684 | 684 | def test_start_tls_client_reg_proto_1(self): | |
| 685 | 685 | HELLO_MSG = b'1' * self.PAYLOAD_SIZE | |
| 686 | 686 | ||
@@ -742,7 +742,7 @@ async def client(addr): | |||
| 742 | 742 | asyncio.wait_for(client(srv.addr), | |
| 743 | 743 | timeout=support.SHORT_TIMEOUT)) | |
| 744 | 744 | ||
| 745 | - @unittest.skip('TODO: RUSTPYTHON; RuntimeError: Event loop stopped before Future completed.') | ||
| 745 | + @unittest.expectedFailure # TODO: RUSTPYTHON; RuntimeError: Event loop stopped before Future completed. | ||
| 746 | 746 | def test_create_connection_memory_leak(self): | |
| 747 | 747 | HELLO_MSG = b'1' * self.PAYLOAD_SIZE | |
| 748 | 748 | ||
@@ -807,7 +807,7 @@ async def client(addr): | |||
| 807 | 807 | client_context = weakref.ref(client_context) | |
| 808 | 808 | self.assertIsNone(client_context()) | |
| 809 | 809 | ||
| 810 | - @unittest.skip('TODO: RUSTPYTHON; RuntimeError: Event loop stopped before Future completed.') | ||
| 810 | + @unittest.expectedFailure # TODO: RUSTPYTHON; RuntimeError: Event loop stopped before Future completed. | ||
| 811 | 811 | def test_start_tls_client_buf_proto_1(self): | |
| 812 | 812 | HELLO_MSG = b'1' * self.PAYLOAD_SIZE | |
| 813 | 813 | ||
@@ -964,7 +964,7 @@ async def client(addr): | |||
| 964 | 964 | asyncio.wait_for(client(srv.addr), | |
| 965 | 965 | timeout=support.SHORT_TIMEOUT)) | |
| 966 | 966 | ||
| 967 | - @unittest.skip('TODO: RUSTPYTHON; RuntimeError: Event loop stopped before Future completed.') | ||
| 967 | + @unittest.expectedFailure # TODO: RUSTPYTHON; RuntimeError: Event loop stopped before Future completed. | ||
| 968 | 968 | def test_start_tls_server_1(self): | |
| 969 | 969 | HELLO_MSG = b'1' * self.PAYLOAD_SIZE | |
| 970 | 970 | ||
@@ -1189,7 +1189,7 @@ async def start_server(): | |||
| 1189 | 1189 | for client in clients: | |
| 1190 | 1190 | client.stop() | |
| 1191 | 1191 | ||
| 1192 | - @unittest.skip('TODO: RUSTPYTHON; RuntimeError: Event loop stopped before Future completed.') | ||
| 1192 | + @unittest.expectedFailure # TODO: RUSTPYTHON; RuntimeError: Event loop stopped before Future completed. | ||
| 1193 | 1193 | def test_shutdown_cleanly(self): | |
| 1194 | 1194 | CNT = 0 | |
| 1195 | 1195 | TOTAL_CNT = 25 | |
@@ -1315,7 +1315,7 @@ async def client(addr): | |||
| 1315 | 1315 | with self.tcp_server(run(server)) as srv: | |
| 1316 | 1316 | self.loop.run_until_complete(client(srv.addr)) | |
| 1317 | 1317 | ||
| 1318 | - @unittest.skip('TODO: RUSTPYTHON; ssl_error.SSLError: cannot read after shutdown') | ||
| 1318 | + @unittest.expectedFailure # TODO: RUSTPYTHON; ssl_error.SSLError: cannot read after shutdown | ||
| 1319 | 1319 | def test_remote_shutdown_receives_trailing_data(self): | |
| 1320 | 1320 | CHUNK = 1024 * 128 | |
| 1321 | 1321 | SIZE = 32 | |
@@ -1440,7 +1440,7 @@ def wrapper(sock): | |||
| 1440 | 1440 | with self.tcp_server(run(eof_server)) as srv: | |
| 1441 | 1441 | self.loop.run_until_complete(client(srv.addr)) | |
| 1442 | 1442 | ||
| 1443 | - @unittest.skip('TODO: RUSTPYTHON; ssl_error.SSLError: cannot read after shutdown') | ||
| 1443 | + @unittest.expectedFailure # TODO: RUSTPYTHON; ssl_error.SSLError: cannot read after shutdown | ||
| 1444 | 1444 | def test_remote_shutdown_receives_trailing_data_on_slow_socket(self): | |
| 1445 | 1445 | # This test is the same as test_remote_shutdown_receives_trailing_data, | |
| 1446 | 1446 | # except it simulates a socket that is not able to write data in time, | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -1246,7 +1246,7 @@ async def handle_echo(reader, writer): | |||
| 1246 | 1246 | messages = self._basetest_unhandled_exceptions(handle_echo) | |
| 1247 | 1247 | self.assertEqual(messages, []) | |
| 1248 | 1248 | ||
| 1249 | - @unittest.skip('TODO: RUSTPYTHON; NotImplementedError') | ||
| 1249 | + @unittest.expectedFailure # TODO: RUSTPYTHON; NotImplementedError | ||
| 1250 | 1250 | def test_open_connection_happy_eyeball_refcycles(self): | |
| 1251 | 1251 | port = socket_helper.find_unused_port() | |
| 1252 | 1252 | async def main(): | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -918,7 +918,7 @@ async def outer(): | |||
| 918 | 918 | ||
| 919 | 919 | await outer() | |
| 920 | 920 | ||
| 921 | - @unittest.skip('TODO: RUSTPYTHON; NotImplementedError') | ||
| 921 | + @unittest.expectedFailure # TODO: RUSTPYTHON; NotImplementedError | ||
| 922 | 922 | async def test_exception_refcycles_direct(self): | |
| 923 | 923 | """Test that TaskGroup doesn't keep a reference to the raised ExceptionGroup""" | |
| 924 | 924 | tg = asyncio.TaskGroup() | |
@@ -936,7 +936,7 @@ class _Done(Exception): | |||
| 936 | 936 | self.assertIsNotNone(exc) | |
| 937 | 937 | self.assertListEqual(gc.get_referrers(exc), []) | |
| 938 | 938 | ||
| 939 | - @unittest.skip('TODO: RUSTPYTHON; NotImplementedError') | ||
| 939 | + @unittest.expectedFailure # TODO: RUSTPYTHON; NotImplementedError | ||
| 940 | 940 | async def test_exception_refcycles_errors(self): | |
| 941 | 941 | """Test that TaskGroup deletes self._errors, and __aexit__ args""" | |
| 942 | 942 | tg = asyncio.TaskGroup() | |
@@ -954,7 +954,7 @@ class _Done(Exception): | |||
| 954 | 954 | self.assertIsInstance(exc, _Done) | |
| 955 | 955 | self.assertListEqual(gc.get_referrers(exc), []) | |
| 956 | 956 | ||
| 957 | - @unittest.skip('TODO: RUSTPYTHON; NotImplementedError') | ||
| 957 | + @unittest.expectedFailure # TODO: RUSTPYTHON; NotImplementedError | ||
| 958 | 958 | async def test_exception_refcycles_parent_task(self): | |
| 959 | 959 | """Test that TaskGroup deletes self._parent_task""" | |
| 960 | 960 | tg = asyncio.TaskGroup() | |
@@ -976,7 +976,7 @@ async def coro_fn(): | |||
| 976 | 976 | self.assertIsInstance(exc, _Done) | |
| 977 | 977 | self.assertListEqual(gc.get_referrers(exc), []) | |
| 978 | 978 | ||
| 979 | - @unittest.skip('TODO: RUSTPYTHON; NotImplementedError for gc.disable()') | ||
| 979 | + @unittest.expectedFailure # TODO: RUSTPYTHON; NotImplementedError for gc.disable() | ||
| 980 | 980 | async def test_exception_refcycles_parent_task_wr(self): | |
| 981 | 981 | """Test that TaskGroup deletes self._parent_task and create_task() deletes task""" | |
| 982 | 982 | tg = asyncio.TaskGroup() | |
@@ -1000,7 +1000,7 @@ async def coro_fn(): | |||
| 1000 | 1000 | self.assertIsInstance(exc, _Done) | |
| 1001 | 1001 | self.assertListEqual(gc.get_referrers(exc), []) | |
| 1002 | 1002 | ||
| 1003 | - @unittest.skip('TODO: RUSTPYTHON; NotImplementedError for asyncio.CancelledError') | ||
| 1003 | + @unittest.expectedFailure # TODO: RUSTPYTHON; NotImplementedError for asyncio.CancelledError | ||
| 1004 | 1004 | async def test_exception_refcycles_propagate_cancellation_error(self): | |
| 1005 | 1005 | """Test that TaskGroup deletes propagate_cancellation_error""" | |
| 1006 | 1006 | tg = asyncio.TaskGroup() | |
@@ -1016,7 +1016,7 @@ async def test_exception_refcycles_propagate_cancellation_error(self): | |||
| 1016 | 1016 | self.assertIsInstance(exc, asyncio.CancelledError) | |
| 1017 | 1017 | self.assertListEqual(gc.get_referrers(exc), []) | |
| 1018 | 1018 | ||
| 1019 | - @unittest.skip('TODO: RUSTPYTHON; NotImplementedError for coro.send(None)') | ||
| 1019 | + @unittest.expectedFailure # TODO: RUSTPYTHON; NotImplementedError for coro.send(None) | ||
| 1020 | 1020 | async def test_exception_refcycles_base_error(self): | |
| 1021 | 1021 | """Test that TaskGroup deletes self._base_error""" | |
| 1022 | 1022 | class MyKeyboardInterrupt(KeyboardInterrupt): | |
| Back | FazBrowse Home | New Git URL |
0 commit comments