Linux server1.dn-server.com 4.18.0-553.89.1.lve.el8.x86_64 #1 SMP Wed Dec 10 13:58:50 UTC 2025 x86_64
LiteSpeed
Server IP : 195.201.204.189 & Your IP : 216.73.216.198
Domains :
Cant Read [ /etc/named.conf ]
User : beriska1
Terminal
Auto Root
Create File
Create Folder
Localroot Suggester
Backdoor Destroyer
Readme
/
opt /
alt /
python313 /
lib64 /
python3.13 /
test /
Delete
Unzip
Name
Size
Permission
Date
Action
__pycache__
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
archivetestdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
audiodata
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
certdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
cjkencodings
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
configdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
crashers
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
data
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
decimaltestdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
dtracedata
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
encoded_modules
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
leakers
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
libregrtest
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
mathdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
regrtestdata
[ DIR ]
drwxr-xr-x
2026-03-26 17:37
subprocessdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
support
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_ast
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_asyncio
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_capi
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_cext
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_concurrent_futures
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_cppext
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_ctypes
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_dataclasses
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_doctest
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_email
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_free_threading
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_future_stmt
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_gdb
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_import
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_importlib
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_inspect
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_interpreters
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_json
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_module
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_multiprocessing_fork
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_multiprocessing_forkserver
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_multiprocessing_spawn
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_pathlib
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_peg_generator
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_pydoc
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_pyrepl
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_sqlite3
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_tkinter
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_tomllib
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_tools
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_ttk
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_unittest
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_warnings
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_zipfile
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
test_zoneinfo
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
tkinterdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
tokenizedata
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
tracedmodules
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
translationdata
[ DIR ]
drwxr-xr-x
2026-03-26 17:37
typinganndata
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
wheeldata
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
xmltestdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
zipimport_data
[ DIR ]
drwxr-xr-x
2026-05-05 23:06
NormalizationTest-3.2.0.txt
1.93
MB
-rw-r--r--
2026-02-03 21:23
__init__.py
47
B
-rw-r--r--
2026-03-26 17:22
__main__.py
67
B
-rw-r--r--
2026-03-26 17:22
_test_atexit.py
5.32
KB
-rw-r--r--
2026-03-26 17:22
_test_eintr.py
17.83
KB
-rw-r--r--
2026-03-26 17:22
_test_embed_set_config.py
9.32
KB
-rw-r--r--
2026-03-26 17:22
_test_embed_structseq.py
1.99
KB
-rw-r--r--
2026-03-26 17:22
_test_monitoring_shutdown.py
704
B
-rw-r--r--
2026-03-26 17:39
_test_multiprocessing.py
228.26
KB
-rw-r--r--
2026-03-26 17:22
_test_venv_multiprocessing.py
796
B
-rw-r--r--
2026-03-26 17:22
archiver_tests.py
7.06
KB
-rw-r--r--
2026-03-26 17:22
audiotests.py
12.13
KB
-rw-r--r--
2026-03-26 17:22
audit-tests.py
14.81
KB
-rw-r--r--
2026-03-26 17:22
autotest.py
214
B
-rw-r--r--
2026-03-26 17:22
bisect_cmd.py
5.36
KB
-rwxr-xr-x
2026-03-26 17:22
clinic.test.c
161.63
KB
-rw-r--r--
2026-02-03 21:23
cov.py
1.26
KB
-rw-r--r--
2026-03-26 17:22
curses_tests.py
1.23
KB
-rwxr-xr-x
2026-03-26 17:22
datetimetester.py
274.67
KB
-rw-r--r--
2026-03-26 17:22
dis_module.py
76
B
-rw-r--r--
2026-03-26 17:22
empty.vbs
70
B
-rw-r--r--
2026-02-03 21:23
exception_hierarchy.txt
2.38
KB
-rw-r--r--
2026-02-03 21:23
fork_wait.py
2.29
KB
-rw-r--r--
2026-03-26 17:22
levenshtein_examples.json
406.44
KB
-rw-r--r--
2026-02-03 21:23
list_tests.py
17.11
KB
-rw-r--r--
2026-03-26 17:22
lock_tests.py
35.64
KB
-rw-r--r--
2026-03-26 17:22
mapping_tests.py
21.87
KB
-rw-r--r--
2026-03-26 17:22
memory_watchdog.py
711
B
-rw-r--r--
2026-03-26 17:22
mime.types
47.37
KB
-rw-r--r--
2026-02-03 21:23
mock_socket.py
3.69
KB
-rw-r--r--
2026-03-26 17:22
mp_fork_bomb.py
448
B
-rw-r--r--
2026-03-26 17:22
mp_preload.py
351
B
-rw-r--r--
2026-03-26 17:22
mp_preload_flush.py
291
B
-rw-r--r--
2026-03-26 17:22
mp_preload_main.py
287
B
-rw-r--r--
2026-03-26 17:22
mp_preload_sysargv.py
567
B
-rw-r--r--
2026-03-26 17:22
multibytecodec_support.py
14.91
KB
-rw-r--r--
2026-03-26 17:22
picklecommon.py
9.4
KB
-rw-r--r--
2026-03-26 17:22
pickletester.py
179.95
KB
-rw-r--r--
2026-03-26 17:22
profilee.py
2.97
KB
-rw-r--r--
2026-03-26 17:22
pstats.pck
65.05
KB
-rw-r--r--
2026-02-03 21:23
pyclbr_input.py
1.63
KB
-rw-r--r--
2026-03-26 17:22
pythoninfo.py
28.65
KB
-rw-r--r--
2026-03-26 17:22
randv2_32.pck
7.34
KB
-rw-r--r--
2026-02-03 21:23
randv2_64.pck
7.19
KB
-rw-r--r--
2026-02-03 21:23
randv3.pck
7.82
KB
-rw-r--r--
2026-02-03 21:23
re_tests.py
25.94
KB
-rwxr-xr-x
2026-03-26 17:22
regrtest.py
1.28
KB
-rwxr-xr-x
2026-03-26 17:22
relimport.py
27
B
-rw-r--r--
2026-03-26 17:22
reperf.py
538
B
-rw-r--r--
2026-03-26 17:22
seq_tests.py
15
KB
-rw-r--r--
2026-03-26 17:22
signalinterproctester.py
3.12
KB
-rw-r--r--
2026-03-26 17:22
ssl_servers.py
7.12
KB
-rw-r--r--
2026-03-26 17:22
ssltests.py
1.01
KB
-rw-r--r--
2026-03-26 17:22
string_tests.py
72.29
KB
-rw-r--r--
2026-03-26 17:22
test___all__.py
4.89
KB
-rw-r--r--
2026-03-26 17:22
test__colorize.py
6.51
KB
-rw-r--r--
2026-03-26 17:22
test__interpchannels.py
61.88
KB
-rw-r--r--
2026-03-26 17:22
test__interpreters.py
36.56
KB
-rw-r--r--
2026-03-26 17:22
test__locale.py
12.52
KB
-rw-r--r--
2026-03-26 17:22
test__opcode.py
5.82
KB
-rw-r--r--
2026-03-26 17:22
test__osx_support.py
13.53
KB
-rw-r--r--
2026-03-26 17:22
test_abc.py
23.81
KB
-rw-r--r--
2026-03-26 17:22
test_abstract_numbers.py
5.81
KB
-rw-r--r--
2026-03-26 17:22
test_android.py
18.37
KB
-rw-r--r--
2026-03-26 17:22
test_apple.py
4.66
KB
-rw-r--r--
2026-03-26 17:22
test_argparse.py
233.02
KB
-rw-r--r--
2026-03-26 17:22
test_array.py
58.79
KB
-rw-r--r--
2026-03-26 17:22
test_asdl_parser.py
4.44
KB
-rw-r--r--
2026-03-26 17:22
test_asyncgen.py
58.05
KB
-rw-r--r--
2026-03-26 17:22
test_atexit.py
3.2
KB
-rw-r--r--
2026-03-26 17:22
test_audit.py
10.24
KB
-rw-r--r--
2026-03-26 17:22
test_augassign.py
7.68
KB
-rw-r--r--
2026-03-26 17:22
test_base64.py
40.3
KB
-rw-r--r--
2026-03-26 17:22
test_baseexception.py
7.92
KB
-rw-r--r--
2026-03-26 17:22
test_bdb.py
44.6
KB
-rw-r--r--
2026-03-26 17:22
test_bigaddrspace.py
2.83
KB
-rw-r--r--
2026-03-26 17:22
test_bigmem.py
45.01
KB
-rw-r--r--
2026-03-26 17:22
test_binascii.py
22.16
KB
-rw-r--r--
2026-03-26 17:22
test_binop.py
14.14
KB
-rw-r--r--
2026-03-26 17:22
test_bisect.py
16.63
KB
-rw-r--r--
2026-03-26 17:22
test_bool.py
14.25
KB
-rw-r--r--
2026-03-26 17:22
test_buffer.py
173.64
KB
-rw-r--r--
2026-03-26 17:22
test_bufio.py
2.56
KB
-rw-r--r--
2026-03-26 17:22
test_builtin.py
101.42
KB
-rw-r--r--
2026-03-26 17:22
test_bytes.py
88.54
KB
-rw-r--r--
2026-03-26 17:22
test_bz2.py
45.25
KB
-rw-r--r--
2026-03-26 17:22
test_c_locale_coercion.py
20.96
KB
-rw-r--r--
2026-03-26 17:22
test_calendar.py
57.9
KB
-rw-r--r--
2026-03-26 17:22
test_call.py
39.54
KB
-rw-r--r--
2026-03-26 17:22
test_charmapcodec.py
1.77
KB
-rw-r--r--
2026-03-26 17:22
test_class.py
28.72
KB
-rw-r--r--
2026-03-26 17:22
test_clinic.py
146.98
KB
-rw-r--r--
2026-03-26 17:22
test_cmath.py
22.47
KB
-rw-r--r--
2026-03-26 17:22
test_cmd.py
7.82
KB
-rw-r--r--
2026-03-26 17:22
test_cmd_line.py
43.25
KB
-rw-r--r--
2026-03-26 17:22
test_cmd_line_script.py
36.12
KB
-rw-r--r--
2026-03-26 17:22
test_code.py
28.35
KB
-rw-r--r--
2026-03-26 17:22
test_code_module.py
13.46
KB
-rw-r--r--
2026-03-26 17:22
test_codeccallbacks.py
49.23
KB
-rw-r--r--
2026-03-26 17:22
test_codecencodings_cn.py
3.86
KB
-rw-r--r--
2026-03-26 17:22
test_codecencodings_hk.py
701
B
-rw-r--r--
2026-03-26 17:22
test_codecencodings_iso2022.py
3.65
KB
-rw-r--r--
2026-03-26 17:22
test_codecencodings_jp.py
4.79
KB
-rw-r--r--
2026-03-26 17:22
test_codecencodings_kr.py
2.96
KB
-rw-r--r--
2026-03-26 17:22
test_codecencodings_tw.py
681
B
-rw-r--r--
2026-03-26 17:22
test_codecmaps_cn.py
746
B
-rw-r--r--
2026-03-26 17:22
test_codecmaps_hk.py
386
B
-rw-r--r--
2026-03-26 17:22
test_codecmaps_jp.py
1.7
KB
-rw-r--r--
2026-03-26 17:22
test_codecmaps_kr.py
1.16
KB
-rw-r--r--
2026-03-26 17:22
test_codecmaps_tw.py
705
B
-rw-r--r--
2026-03-26 17:22
test_codecs.py
147.37
KB
-rw-r--r--
2026-03-26 17:22
test_codeop.py
8.68
KB
-rw-r--r--
2026-03-26 17:22
test_collections.py
93.72
KB
-rw-r--r--
2026-03-26 17:22
test_colorsys.py
4.27
KB
-rw-r--r--
2026-03-26 17:22
test_compare.py
17.46
KB
-rw-r--r--
2026-03-26 17:22
test_compile.py
95.51
KB
-rw-r--r--
2026-03-26 17:22
test_compileall.py
49.53
KB
-rw-r--r--
2026-03-26 17:22
test_compiler_assemble.py
4.79
KB
-rw-r--r--
2026-03-26 17:22
test_compiler_codegen.py
5.24
KB
-rw-r--r--
2026-03-26 17:22
test_complex.py
35.29
KB
-rw-r--r--
2026-03-26 17:22
test_configparser.py
87.21
KB
-rw-r--r--
2026-03-26 17:22
test_contains.py
3.35
KB
-rw-r--r--
2026-03-26 17:22
test_context.py
32.03
KB
-rw-r--r--
2026-03-26 17:22
test_contextlib.py
43.35
KB
-rw-r--r--
2026-03-26 17:22
test_contextlib_async.py
23.45
KB
-rw-r--r--
2026-03-26 17:22
test_copy.py
29.45
KB
-rw-r--r--
2026-03-26 17:22
test_copyreg.py
4.36
KB
-rw-r--r--
2026-03-26 17:22
test_coroutines.py
67.59
KB
-rw-r--r--
2026-03-26 17:22
test_cprofile.py
9.74
KB
-rw-r--r--
2026-03-26 17:22
test_csv.py
64.09
KB
-rw-r--r--
2026-03-26 17:22
test_curses.py
50.42
KB
-rw-r--r--
2026-03-26 17:22
test_datetime.py
2.67
KB
-rw-r--r--
2026-03-26 17:22
test_dbm.py
8.26
KB
-rw-r--r--
2026-03-26 17:22
test_dbm_dumb.py
14.29
KB
-rw-r--r--
2026-03-26 17:22
test_dbm_gnu.py
8.03
KB
-rw-r--r--
2026-03-26 17:22
test_dbm_ndbm.py
6.3
KB
-rw-r--r--
2026-03-26 17:22
test_dbm_sqlite3.py
10.84
KB
-rw-r--r--
2026-03-26 17:22
test_decimal.py
216.81
KB
-rw-r--r--
2026-03-26 17:22
test_decorators.py
10.73
KB
-rw-r--r--
2026-03-26 17:22
test_defaultdict.py
6.56
KB
-rw-r--r--
2026-03-26 17:22
test_deque.py
33.16
KB
-rw-r--r--
2026-03-26 17:22
test_descr.py
197.53
KB
-rw-r--r--
2026-03-26 17:22
test_descrtut.py
11.02
KB
-rw-r--r--
2026-03-26 17:22
test_devpoll.py
4.44
KB
-rw-r--r--
2026-03-26 17:22
test_dict.py
55.39
KB
-rw-r--r--
2026-03-26 17:22
test_dict_version.py
6.1
KB
-rw-r--r--
2026-03-26 17:22
test_dictcomps.py
6.55
KB
-rw-r--r--
2026-03-26 17:22
test_dictviews.py
14.82
KB
-rw-r--r--
2026-03-26 17:22
test_difflib.py
22.99
KB
-rw-r--r--
2026-03-26 17:22
test_difflib_expect.html
100.9
KB
-rw-r--r--
2026-02-03 21:23
test_dis.py
105.91
KB
-rw-r--r--
2026-03-26 17:22
test_docxmlrpc.py
9.1
KB
-rw-r--r--
2026-03-26 17:22
test_dtrace.py
7.98
KB
-rw-r--r--
2026-03-26 17:22
test_dynamic.py
6.08
KB
-rw-r--r--
2026-03-26 17:22
test_dynamicclassattribute.py
9.57
KB
-rw-r--r--
2026-03-26 17:22
test_eintr.py
627
B
-rw-r--r--
2026-03-26 17:22
test_embed.py
74.88
KB
-rw-r--r--
2026-03-26 17:22
test_ensurepip.py
11.49
KB
-rw-r--r--
2026-03-26 17:22
test_enum.py
196.11
KB
-rw-r--r--
2026-03-26 17:22
test_enumerate.py
9.14
KB
-rw-r--r--
2026-03-26 17:22
test_eof.py
8.01
KB
-rw-r--r--
2026-03-26 17:22
test_epoll.py
9.4
KB
-rw-r--r--
2026-03-26 17:22
test_errno.py
1.04
KB
-rw-r--r--
2026-03-26 17:22
test_except_star.py
39.7
KB
-rw-r--r--
2026-03-26 17:22
test_exception_group.py
37.06
KB
-rw-r--r--
2026-03-26 17:22
test_exception_hierarchy.py
7.54
KB
-rw-r--r--
2026-03-26 17:22
test_exception_variations.py
13.74
KB
-rw-r--r--
2026-03-26 17:22
test_exceptions.py
87.23
KB
-rw-r--r--
2026-03-26 17:22
test_extcall.py
14.69
KB
-rw-r--r--
2026-03-26 17:22
test_external_inspection.py
2.96
KB
-rw-r--r--
2026-03-26 17:22
test_faulthandler.py
31.47
KB
-rw-r--r--
2026-03-26 17:22
test_fcntl.py
8.59
KB
-rw-r--r--
2026-03-26 17:22
test_file.py
11.78
KB
-rw-r--r--
2026-03-26 17:22
test_file_eintr.py
10.74
KB
-rw-r--r--
2026-03-26 17:22
test_filecmp.py
15.66
KB
-rw-r--r--
2026-03-26 17:22
test_fileinput.py
37.86
KB
-rw-r--r--
2026-03-26 17:22
test_fileio.py
20.72
KB
-rw-r--r--
2026-03-26 17:22
test_fileutils.py
951
B
-rw-r--r--
2026-03-26 17:22
test_finalization.py
14.67
KB
-rw-r--r--
2026-03-26 17:22
test_float.py
65.38
KB
-rw-r--r--
2026-03-26 17:22
test_flufl.py
2.81
KB
-rw-r--r--
2026-03-26 17:22
test_fnmatch.py
10.68
KB
-rw-r--r--
2026-03-26 17:22
test_fork1.py
3.3
KB
-rw-r--r--
2026-03-26 17:22
test_format.py
28.54
KB
-rw-r--r--
2026-03-26 17:22
test_fractions.py
67.44
KB
-rw-r--r--
2026-03-26 17:22
test_frame.py
23.28
KB
-rw-r--r--
2026-03-26 17:22
test_frozen.py
2.2
KB
-rw-r--r--
2026-03-26 17:22
test_fstring.py
70.92
KB
-rw-r--r--
2026-03-26 17:22
test_ftplib.py
42.06
KB
-rw-r--r--
2026-03-26 17:22
test_funcattrs.py
17.29
KB
-rw-r--r--
2026-03-26 17:22
test_functools.py
118.41
KB
-rw-r--r--
2026-03-26 17:22
test_gc.py
52.16
KB
-rw-r--r--
2026-03-26 17:22
test_generated_cases.py
27.14
KB
-rw-r--r--
2026-03-26 17:22
test_generator_stop.py
943
B
-rw-r--r--
2026-03-26 17:22
test_generators.py
74.12
KB
-rw-r--r--
2026-03-26 17:22
test_genericalias.py
20
KB
-rw-r--r--
2026-03-26 17:22
test_genericclass.py
9.57
KB
-rw-r--r--
2026-03-26 17:22
test_genericpath.py
23.37
KB
-rw-r--r--
2026-03-26 17:22
test_genexps.py
7.3
KB
-rw-r--r--
2026-03-26 17:22
test_getopt.py
6.94
KB
-rw-r--r--
2026-03-26 17:22
test_getpass.py
6.36
KB
-rw-r--r--
2026-03-26 17:22
test_getpath.py
44.84
KB
-rw-r--r--
2026-03-26 17:22
test_gettext.py
45.41
KB
-rw-r--r--
2026-03-26 17:22
test_glob.py
24.29
KB
-rw-r--r--
2026-03-26 17:22
test_global.py
1.2
KB
-rw-r--r--
2026-03-26 17:22
test_grammar.py
64.9
KB
-rw-r--r--
2026-03-26 17:22
test_graphlib.py
8.31
KB
-rw-r--r--
2026-03-26 17:22
test_grp.py
3.67
KB
-rw-r--r--
2026-03-26 17:22
test_gzip.py
41.97
KB
-rw-r--r--
2026-03-26 17:22
test_hash.py
12.11
KB
-rw-r--r--
2026-03-26 17:22
test_hashlib.py
50.69
KB
-rw-r--r--
2026-03-26 17:22
test_heapq.py
16.42
KB
-rw-r--r--
2026-03-26 17:22
test_hmac.py
26.49
KB
-rw-r--r--
2026-03-26 17:22
test_html.py
4.23
KB
-rw-r--r--
2026-03-26 17:22
test_htmlparser.py
51.09
KB
-rw-r--r--
2026-03-26 17:22
test_http_cookiejar.py
81.84
KB
-rw-r--r--
2026-03-26 17:22
test_http_cookies.py
23.65
KB
-rw-r--r--
2026-03-26 17:22
test_httplib.py
99.32
KB
-rw-r--r--
2026-03-26 17:22
test_httpservers.py
62.86
KB
-rw-r--r--
2026-03-26 17:22
test_idle.py
862
B
-rw-r--r--
2026-03-26 17:22
test_imaplib.py
39.24
KB
-rw-r--r--
2026-03-26 17:22
test_index.py
8.37
KB
-rw-r--r--
2026-03-26 17:22
test_int.py
34.84
KB
-rw-r--r--
2026-03-26 17:22
test_int_literal.py
6.89
KB
-rw-r--r--
2026-03-26 17:22
test_io.py
186.35
KB
-rw-r--r--
2026-03-26 17:22
test_ioctl.py
8.42
KB
-rw-r--r--
2026-03-26 17:22
test_ipaddress.py
128.86
KB
-rw-r--r--
2026-03-26 17:22
test_isinstance.py
12.96
KB
-rw-r--r--
2026-03-26 17:22
test_iter.py
38.22
KB
-rw-r--r--
2026-03-26 17:22
test_iterlen.py
7.1
KB
-rw-r--r--
2026-03-26 17:22
test_itertools.py
114.87
KB
-rw-r--r--
2026-03-26 17:22
test_keyword.py
2
KB
-rw-r--r--
2026-03-26 17:22
test_keywordonlyarg.py
6.89
KB
-rw-r--r--
2026-03-26 17:22
test_kqueue.py
9.36
KB
-rw-r--r--
2026-03-26 17:22
test_largefile.py
11.02
KB
-rw-r--r--
2026-03-26 17:22
test_launcher.py
30.61
KB
-rw-r--r--
2026-03-26 17:22
test_linecache.py
14.18
KB
-rw-r--r--
2026-03-26 17:22
test_list.py
10.94
KB
-rw-r--r--
2026-03-26 17:22
test_listcomps.py
23.53
KB
-rw-r--r--
2026-03-26 17:22
test_lltrace.py
3.71
KB
-rw-r--r--
2026-03-26 17:22
test_locale.py
26.37
KB
-rw-r--r--
2026-03-26 17:22
test_logging.py
261.1
KB
-rw-r--r--
2026-03-26 17:22
test_long.py
64.49
KB
-rw-r--r--
2026-03-26 17:22
test_longexp.py
233
B
-rw-r--r--
2026-03-26 17:22
test_lzma.py
95.71
KB
-rw-r--r--
2026-03-26 17:22
test_mailbox.py
99.06
KB
-rw-r--r--
2026-03-26 17:22
test_marshal.py
25.23
KB
-rw-r--r--
2026-03-26 17:22
test_math.py
120.29
KB
-rw-r--r--
2026-03-26 17:22
test_math_property.py
1.15
KB
-rw-r--r--
2026-03-26 17:22
test_memoryio.py
35.23
KB
-rw-r--r--
2026-03-26 17:22
test_memoryview.py
24.12
KB
-rw-r--r--
2026-03-26 17:22
test_metaclass.py
6.97
KB
-rw-r--r--
2026-03-26 17:22
test_mimetypes.py
17.91
KB
-rw-r--r--
2026-03-26 17:22
test_minidom.py
72.31
KB
-rw-r--r--
2026-03-26 17:22
test_mmap.py
45.55
KB
-rw-r--r--
2026-03-26 17:22
test_modulefinder.py
12.21
KB
-rw-r--r--
2026-03-26 17:22
test_monitoring.py
69.38
KB
-rw-r--r--
2026-03-26 17:22
test_msvcrt.py
3.39
KB
-rw-r--r--
2026-03-26 17:22
test_multibytecodec.py
15.87
KB
-rw-r--r--
2026-03-26 17:22
test_multiprocessing_main_handling.py
11.48
KB
-rw-r--r--
2026-03-26 17:22
test_named_expressions.py
29.62
KB
-rw-r--r--
2026-03-26 17:22
test_netrc.py
12.09
KB
-rw-r--r--
2026-03-26 17:22
test_ntpath.py
75.9
KB
-rw-r--r--
2026-03-26 17:22
test_numeric_tower.py
8
KB
-rw-r--r--
2026-03-26 17:22
test_opcache.py
29.7
KB
-rw-r--r--
2026-03-26 17:22
test_opcodes.py
3.62
KB
-rw-r--r--
2026-03-26 17:22
test_openpty.py
600
B
-rw-r--r--
2026-03-26 17:22
test_operator.py
27.71
KB
-rw-r--r--
2026-03-26 17:22
test_optimizer.py
2.61
KB
-rw-r--r--
2026-03-26 17:22
test_optparse.py
61.39
KB
-rw-r--r--
2026-03-26 17:22
test_ordered_dict.py
40.01
KB
-rw-r--r--
2026-03-26 17:22
test_os.py
202.8
KB
-rw-r--r--
2026-03-26 17:22
test_osx_env.py
1.31
KB
-rw-r--r--
2026-03-26 17:22
test_patma.py
94.55
KB
-rw-r--r--
2026-03-26 17:22
test_pdb.py
133.58
KB
-rw-r--r--
2026-03-26 17:22
test_peepholer.py
43.65
KB
-rw-r--r--
2026-03-26 17:22
test_pep646_syntax.py
7.79
KB
-rw-r--r--
2026-03-26 17:22
test_perf_profiler.py
18.83
KB
-rw-r--r--
2026-03-26 17:22
test_perfmaps.py
773
B
-rw-r--r--
2026-03-26 17:22
test_pickle.py
27.61
KB
-rw-r--r--
2026-03-26 17:22
test_picklebuffer.py
4.99
KB
-rw-r--r--
2026-03-26 17:22
test_pickletools.py
16.78
KB
-rw-r--r--
2026-03-26 17:22
test_pkg.py
9.58
KB
-rw-r--r--
2026-03-26 17:22
test_pkgutil.py
26.22
KB
-rw-r--r--
2026-03-26 17:22
test_platform.py
26.69
KB
-rw-r--r--
2026-03-26 17:22
test_plistlib.py
48.91
KB
-rw-r--r--
2026-03-26 17:22
test_poll.py
7.49
KB
-rw-r--r--
2026-03-26 17:22
test_popen.py
2.36
KB
-rw-r--r--
2026-03-26 17:22
test_poplib.py
18.07
KB
-rw-r--r--
2026-03-26 17:22
test_positional_only_arg.py
18.44
KB
-rw-r--r--
2026-03-26 17:22
test_posix.py
99.63
KB
-rw-r--r--
2026-03-26 17:22
test_posixpath.py
51.64
KB
-rw-r--r--
2026-03-26 17:22
test_pow.py
6.38
KB
-rw-r--r--
2026-03-26 17:22
test_pprint.py
39.08
KB
-rw-r--r--
2026-03-26 17:22
test_print.py
8.05
KB
-rw-r--r--
2026-03-26 17:22
test_profile.py
8.95
KB
-rw-r--r--
2026-03-26 17:22
test_property.py
20.12
KB
-rw-r--r--
2026-03-26 17:22
test_pstats.py
5.38
KB
-rw-r--r--
2026-03-26 17:22
test_pty.py
16.18
KB
-rw-r--r--
2026-03-26 17:22
test_pulldom.py
12.33
KB
-rw-r--r--
2026-03-26 17:22
test_pwd.py
4.32
KB
-rw-r--r--
2026-03-26 17:22
test_py_compile.py
11.93
KB
-rw-r--r--
2026-03-26 17:22
test_pyclbr.py
10.11
KB
-rw-r--r--
2026-03-26 17:22
test_pyexpat.py
39.85
KB
-rw-r--r--
2026-03-26 17:22
test_queue.py
33.55
KB
-rw-r--r--
2026-03-26 17:22
test_quopri.py
7.87
KB
-rw-r--r--
2026-03-26 17:22
test_raise.py
13.85
KB
-rw-r--r--
2026-03-26 17:22
test_random.py
60.35
KB
-rw-r--r--
2026-03-26 17:22
test_range.py
26.99
KB
-rw-r--r--
2026-03-26 17:22
test_re.py
147.27
KB
-rw-r--r--
2026-03-26 17:22
test_readline.py
16.15
KB
-rw-r--r--
2026-03-26 17:22
test_regrtest.py
98.35
KB
-rw-r--r--
2026-03-26 17:22
test_repl.py
14.52
KB
-rw-r--r--
2026-03-26 17:22
test_reprlib.py
30.43
KB
-rw-r--r--
2026-03-26 17:22
test_resource.py
11.12
KB
-rw-r--r--
2026-03-26 17:22
test_richcmp.py
11.95
KB
-rw-r--r--
2026-03-26 17:22
test_rlcompleter.py
7.96
KB
-rw-r--r--
2026-03-26 17:22
test_robotparser.py
15.6
KB
-rw-r--r--
2026-03-26 17:22
test_runpy.py
34.12
KB
-rw-r--r--
2026-03-26 17:22
test_sax.py
54.63
KB
-rw-r--r--
2026-03-26 17:22
test_sched.py
7.38
KB
-rw-r--r--
2026-03-26 17:22
test_scope.py
21.94
KB
-rw-r--r--
2026-03-26 17:22
test_script_helper.py
5.82
KB
-rw-r--r--
2026-03-26 17:22
test_secrets.py
4.28
KB
-rw-r--r--
2026-03-26 17:22
test_select.py
3.42
KB
-rw-r--r--
2026-03-26 17:22
test_selectors.py
19.87
KB
-rw-r--r--
2026-03-26 17:22
test_set.py
73.22
KB
-rw-r--r--
2026-03-26 17:22
test_setcomps.py
5.24
KB
-rw-r--r--
2026-03-26 17:22
test_shelve.py
6.42
KB
-rw-r--r--
2026-03-26 17:22
test_shlex.py
13.39
KB
-rw-r--r--
2026-03-26 17:22
test_shutil.py
140.16
KB
-rw-r--r--
2026-03-26 17:22
test_signal.py
52.78
KB
-rw-r--r--
2026-03-26 17:22
test_site.py
36.06
KB
-rw-r--r--
2026-03-26 17:22
test_slice.py
9.46
KB
-rw-r--r--
2026-03-26 17:22
test_smtplib.py
62.33
KB
-rw-r--r--
2026-03-26 17:22
test_smtpnet.py
3.11
KB
-rw-r--r--
2026-03-26 17:22
test_socket.py
271.05
KB
-rw-r--r--
2026-03-26 17:22
test_socketserver.py
17.39
KB
-rw-r--r--
2026-03-26 17:22
test_sort.py
14.48
KB
-rw-r--r--
2026-03-26 17:22
test_source_encoding.py
15.94
KB
-rw-r--r--
2026-03-26 17:22
test_ssl.py
229.41
KB
-rw-r--r--
2026-03-26 17:22
test_stable_abi_ctypes.py
26.22
KB
-rw-r--r--
2026-03-26 17:22
test_startfile.py
1.7
KB
-rw-r--r--
2026-03-26 17:22
test_stat.py
13.25
KB
-rw-r--r--
2026-03-26 17:22
test_statistics.py
131.36
KB
-rw-r--r--
2026-03-26 17:22
test_str.py
126.35
KB
-rw-r--r--
2026-03-26 17:22
test_strftime.py
7.87
KB
-rw-r--r--
2026-03-26 17:22
test_string.py
21.86
KB
-rw-r--r--
2026-03-26 17:22
test_string_literals.py
14.1
KB
-rw-r--r--
2026-03-26 17:22
test_stringprep.py
3.04
KB
-rw-r--r--
2026-03-26 17:22
test_strptime.py
42.79
KB
-rw-r--r--
2026-03-26 17:22
test_strtod.py
20.06
KB
-rw-r--r--
2026-03-26 17:22
test_struct.py
40.47
KB
-rw-r--r--
2026-03-26 17:22
test_structseq.py
14.19
KB
-rw-r--r--
2026-03-26 17:22
test_subclassinit.py
8.04
KB
-rw-r--r--
2026-03-26 17:22
test_subprocess.py
172.83
KB
-rw-r--r--
2026-03-26 17:22
test_sundry.py
1.02
KB
-rw-r--r--
2026-03-26 17:22
test_super.py
15.68
KB
-rw-r--r--
2026-03-26 17:22
test_support.py
27.95
KB
-rw-r--r--
2026-03-26 17:22
test_symtable.py
20.65
KB
-rw-r--r--
2026-03-26 17:22
test_syntax.py
80.5
KB
-rw-r--r--
2026-03-26 17:22
test_sys.py
74.12
KB
-rw-r--r--
2026-03-26 17:22
test_sys_setprofile.py
14.77
KB
-rw-r--r--
2026-03-26 17:22
test_sys_settrace.py
86.74
KB
-rw-r--r--
2026-03-26 17:22
test_sysconfig.py
29.64
KB
-rw-r--r--
2026-03-26 17:22
test_syslog.py
4.7
KB
-rw-r--r--
2026-03-26 17:22
test_tabnanny.py
13.9
KB
-rw-r--r--
2026-03-26 17:22
test_tarfile.py
187.4
KB
-rw-r--r--
2026-03-26 17:22
test_tcl.py
31.6
KB
-rw-r--r--
2026-03-26 17:22
test_tempfile.py
75.5
KB
-rw-r--r--
2026-03-26 17:22
test_termios.py
13.02
KB
-rw-r--r--
2026-03-26 17:22
test_textwrap.py
41.88
KB
-rw-r--r--
2026-03-26 17:22
test_thread.py
14.35
KB
-rw-r--r--
2026-03-26 17:22
test_threadedtempfile.py
2.03
KB
-rw-r--r--
2026-03-26 17:22
test_threading.py
79.5
KB
-rw-r--r--
2026-03-26 17:22
test_threading_local.py
7.01
KB
-rw-r--r--
2026-03-26 17:22
test_threadsignals.py
9.87
KB
-rw-r--r--
2026-03-26 17:22
test_time.py
45.07
KB
-rw-r--r--
2026-03-26 17:22
test_timeit.py
15.2
KB
-rw-r--r--
2026-03-26 17:22
test_timeout.py
10.65
KB
-rw-r--r--
2026-03-26 17:22
test_tokenize.py
121.49
KB
-rw-r--r--
2026-03-26 17:22
test_trace.py
21.72
KB
-rw-r--r--
2026-03-26 17:22
test_traceback.py
187.96
KB
-rw-r--r--
2026-03-26 17:22
test_tracemalloc.py
41.3
KB
-rw-r--r--
2026-03-26 17:22
test_ttk_textonly.py
17.45
KB
-rw-r--r--
2026-03-26 17:22
test_tty.py
3.63
KB
-rw-r--r--
2026-03-26 17:22
test_tuple.py
19.8
KB
-rw-r--r--
2026-03-26 17:22
test_turtle.py
16.42
KB
-rw-r--r--
2026-03-26 17:22
test_type_aliases.py
12.74
KB
-rw-r--r--
2026-03-26 17:22
test_type_annotations.py
6.23
KB
-rw-r--r--
2026-03-26 17:22
test_type_cache.py
7.58
KB
-rw-r--r--
2026-03-26 17:22
test_type_comments.py
11.01
KB
-rw-r--r--
2026-03-26 17:22
test_type_params.py
44.45
KB
-rw-r--r--
2026-03-26 17:22
test_typechecks.py
2.55
KB
-rw-r--r--
2026-03-26 17:22
test_types.py
87.9
KB
-rw-r--r--
2026-03-26 17:22
test_typing.py
373.85
KB
-rw-r--r--
2026-03-26 17:22
test_ucn.py
9.71
KB
-rw-r--r--
2026-03-26 17:22
test_unary.py
1.52
KB
-rw-r--r--
2026-03-26 17:22
test_unicode_file.py
5.72
KB
-rw-r--r--
2026-03-26 17:22
test_unicode_file_functions.py
6.91
KB
-rw-r--r--
2026-03-26 17:22
test_unicode_identifiers.py
997
B
-rw-r--r--
2026-03-26 17:22
test_unicodedata.py
32.39
KB
-rw-r--r--
2026-03-26 17:22
test_univnewlines.py
3.85
KB
-rw-r--r--
2026-03-26 17:22
test_unpack.py
3.51
KB
-rw-r--r--
2026-03-26 17:22
test_unpack_ex.py
9.98
KB
-rw-r--r--
2026-03-26 17:22
test_unparse.py
30
KB
-rw-r--r--
2026-03-26 17:22
test_urllib.py
72.58
KB
-rw-r--r--
2026-03-26 17:22
test_urllib2.py
81.34
KB
-rw-r--r--
2026-03-26 17:22
test_urllib2_localnet.py
24.22
KB
-rw-r--r--
2026-03-26 17:22
test_urllib2net.py
15.6
KB
-rw-r--r--
2026-03-26 17:22
test_urllib_response.py
2.04
KB
-rw-r--r--
2026-03-26 17:22
test_urllibnet.py
9.37
KB
-rw-r--r--
2026-03-26 17:22
test_urlparse.py
79.89
KB
-rw-r--r--
2026-03-26 17:22
test_userdict.py
7.82
KB
-rw-r--r--
2026-03-26 17:22
test_userlist.py
2.23
KB
-rw-r--r--
2026-03-26 17:22
test_userstring.py
2.48
KB
-rw-r--r--
2026-03-26 17:22
test_utf8_mode.py
10.31
KB
-rw-r--r--
2026-03-26 17:22
test_utf8source.py
1.08
KB
-rw-r--r--
2026-03-26 17:22
test_uuid.py
45.51
KB
-rw-r--r--
2026-03-26 17:22
test_venv.py
43.4
KB
-rw-r--r--
2026-03-26 17:22
test_wait3.py
1.74
KB
-rw-r--r--
2026-03-26 17:22
test_wait4.py
1.14
KB
-rw-r--r--
2026-03-26 17:22
test_wave.py
9.12
KB
-rw-r--r--
2026-03-26 17:22
test_weakref.py
78.11
KB
-rw-r--r--
2026-03-26 17:22
test_weakset.py
16.28
KB
-rw-r--r--
2026-03-26 17:22
test_webbrowser.py
17.31
KB
-rw-r--r--
2026-03-26 17:22
test_winapi.py
5.8
KB
-rw-r--r--
2026-03-26 17:22
test_winconsoleio.py
8.06
KB
-rw-r--r--
2026-03-26 17:22
test_winreg.py
23.71
KB
-rw-r--r--
2026-03-26 17:22
test_winsound.py
5.17
KB
-rw-r--r--
2026-03-26 17:22
test_with.py
27.77
KB
-rw-r--r--
2026-03-26 17:22
test_wmi.py
3.31
KB
-rw-r--r--
2026-03-26 17:22
test_wsgiref.py
29.89
KB
-rw-r--r--
2026-03-26 17:22
test_xml_dom_minicompat.py
4.18
KB
-rw-r--r--
2026-03-26 17:22
test_xml_dom_xmlbuilder.py
3.1
KB
-rw-r--r--
2026-03-26 17:22
test_xml_etree.py
176.35
KB
-rw-r--r--
2026-03-26 17:22
test_xml_etree_c.py
9.34
KB
-rw-r--r--
2026-03-26 17:22
test_xmlrpc.py
58.32
KB
-rw-r--r--
2026-03-26 17:22
test_xpickle.py
9.9
KB
-rw-r--r--
2026-03-26 17:22
test_xxlimited.py
2.46
KB
-rw-r--r--
2026-03-26 17:22
test_xxtestfuzz.py
690
B
-rw-r--r--
2026-03-26 17:22
test_yield_from.py
50.36
KB
-rw-r--r--
2026-03-26 17:22
test_zipapp.py
17.58
KB
-rw-r--r--
2026-03-26 17:22
test_zipfile64.py
5.78
KB
-rw-r--r--
2026-03-26 17:22
test_zipimport.py
39.21
KB
-rw-r--r--
2026-03-26 17:22
test_zipimport_support.py
10.61
KB
-rw-r--r--
2026-03-26 17:22
test_zlib.py
41.65
KB
-rw-r--r--
2026-03-26 17:22
testcodec.py
1.02
KB
-rw-r--r--
2026-03-26 17:22
tf_inherit_check.py
714
B
-rw-r--r--
2026-03-26 17:22
win_console_handler.py
1.38
KB
-rw-r--r--
2026-03-26 17:22
xmltests.py
435
B
-rw-r--r--
2026-03-26 17:22
xpickle_worker.py
2.06
KB
-rw-r--r--
2026-03-26 17:22
Save
Rename
import inspect import types import unittest import contextlib from test.support.import_helper import import_module from test.support import gc_collect, requires_working_socket asyncio = import_module("asyncio") requires_working_socket(module=True) _no_default = object() class AwaitException(Exception): pass @types.coroutine def awaitable(*, throw=False): if throw: yield ('throw',) else: yield ('result',) def run_until_complete(coro): exc = False while True: try: if exc: exc = False fut = coro.throw(AwaitException) else: fut = coro.send(None) except StopIteration as ex: return ex.args[0] if fut == ('throw',): exc = True def to_list(gen): async def iterate(): res = [] async for i in gen: res.append(i) return res return run_until_complete(iterate()) def py_anext(iterator, default=_no_default): """Pure-Python implementation of anext() for testing purposes. Closely matches the builtin anext() C implementation. Can be used to compare the built-in implementation of the inner coroutines machinery to C-implementation of __anext__() and send() or throw() on the returned generator. """ try: __anext__ = type(iterator).__anext__ except AttributeError: raise TypeError(f'{iterator!r} is not an async iterator') if default is _no_default: return __anext__(iterator) async def anext_impl(): try: # The C code is way more low-level than this, as it implements # all methods of the iterator protocol. In this implementation # we're relying on higher-level coroutine concepts, but that's # exactly what we want -- crosstest pure-Python high-level # implementation and low-level C anext() iterators. return await __anext__(iterator) except StopAsyncIteration: return default return anext_impl() class AsyncGenSyntaxTest(unittest.TestCase): def test_async_gen_syntax_01(self): code = '''async def foo(): await abc yield from 123 ''' with self.assertRaisesRegex(SyntaxError, 'yield from.*inside async'): exec(code, {}, {}) def test_async_gen_syntax_02(self): code = '''async def foo(): yield from 123 ''' with self.assertRaisesRegex(SyntaxError, 'yield from.*inside async'): exec(code, {}, {}) def test_async_gen_syntax_03(self): code = '''async def foo(): await abc yield return 123 ''' with self.assertRaisesRegex(SyntaxError, 'return.*value.*async gen'): exec(code, {}, {}) def test_async_gen_syntax_04(self): code = '''async def foo(): yield return 123 ''' with self.assertRaisesRegex(SyntaxError, 'return.*value.*async gen'): exec(code, {}, {}) def test_async_gen_syntax_05(self): code = '''async def foo(): if 0: yield return 12 ''' with self.assertRaisesRegex(SyntaxError, 'return.*value.*async gen'): exec(code, {}, {}) class AsyncGenTest(unittest.TestCase): def compare_generators(self, sync_gen, async_gen): def sync_iterate(g): res = [] while True: try: res.append(g.__next__()) except StopIteration: res.append('STOP') break except Exception as ex: res.append(str(type(ex))) return res def async_iterate(g): res = [] while True: an = g.__anext__() try: while True: try: an.__next__() except StopIteration as ex: if ex.args: res.append(ex.args[0]) break else: res.append('EMPTY StopIteration') break except StopAsyncIteration: raise except Exception as ex: res.append(str(type(ex))) break except StopAsyncIteration: res.append('STOP') break return res sync_gen_result = sync_iterate(sync_gen) async_gen_result = async_iterate(async_gen) self.assertEqual(sync_gen_result, async_gen_result) return async_gen_result def test_async_gen_iteration_01(self): async def gen(): await awaitable() a = yield 123 self.assertIs(a, None) await awaitable() yield 456 await awaitable() yield 789 self.assertEqual(to_list(gen()), [123, 456, 789]) def test_async_gen_iteration_02(self): async def gen(): await awaitable() yield 123 await awaitable() g = gen() ai = g.__aiter__() an = ai.__anext__() self.assertEqual(an.__next__(), ('result',)) try: an.__next__() except StopIteration as ex: self.assertEqual(ex.args[0], 123) else: self.fail('StopIteration was not raised') an = ai.__anext__() self.assertEqual(an.__next__(), ('result',)) try: an.__next__() except StopAsyncIteration as ex: self.assertFalse(ex.args) else: self.fail('StopAsyncIteration was not raised') def test_async_gen_exception_03(self): async def gen(): await awaitable() yield 123 await awaitable(throw=True) yield 456 with self.assertRaises(AwaitException): to_list(gen()) def test_async_gen_exception_04(self): async def gen(): await awaitable() yield 123 1 / 0 g = gen() ai = g.__aiter__() an = ai.__anext__() self.assertEqual(an.__next__(), ('result',)) try: an.__next__() except StopIteration as ex: self.assertEqual(ex.args[0], 123) else: self.fail('StopIteration was not raised') with self.assertRaises(ZeroDivisionError): ai.__anext__().__next__() def test_async_gen_exception_05(self): async def gen(): yield 123 raise StopAsyncIteration with self.assertRaisesRegex(RuntimeError, 'async generator.*StopAsyncIteration'): to_list(gen()) def test_async_gen_exception_06(self): async def gen(): yield 123 raise StopIteration with self.assertRaisesRegex(RuntimeError, 'async generator.*StopIteration'): to_list(gen()) def test_async_gen_exception_07(self): def sync_gen(): try: yield 1 1 / 0 finally: yield 2 yield 3 yield 100 async def async_gen(): try: yield 1 1 / 0 finally: yield 2 yield 3 yield 100 self.compare_generators(sync_gen(), async_gen()) def test_async_gen_exception_08(self): def sync_gen(): try: yield 1 finally: yield 2 1 / 0 yield 3 yield 100 async def async_gen(): try: yield 1 await awaitable() finally: await awaitable() yield 2 1 / 0 yield 3 yield 100 self.compare_generators(sync_gen(), async_gen()) def test_async_gen_exception_09(self): def sync_gen(): try: yield 1 1 / 0 finally: yield 2 yield 3 yield 100 async def async_gen(): try: await awaitable() yield 1 1 / 0 finally: yield 2 await awaitable() yield 3 yield 100 self.compare_generators(sync_gen(), async_gen()) def test_async_gen_exception_10(self): async def gen(): yield 123 with self.assertRaisesRegex(TypeError, "non-None value .* async generator"): gen().__anext__().send(100) def test_async_gen_exception_11(self): def sync_gen(): yield 10 yield 20 def sync_gen_wrapper(): yield 1 sg = sync_gen() sg.send(None) try: sg.throw(GeneratorExit()) except GeneratorExit: yield 2 yield 3 async def async_gen(): yield 10 yield 20 async def async_gen_wrapper(): yield 1 asg = async_gen() await asg.asend(None) try: await asg.athrow(GeneratorExit()) except GeneratorExit: yield 2 yield 3 self.compare_generators(sync_gen_wrapper(), async_gen_wrapper()) def test_async_gen_exception_12(self): async def gen(): with self.assertWarnsRegex(RuntimeWarning, f"coroutine method 'asend' of '{gen.__qualname__}' " f"was never awaited"): await anext(me) yield 123 me = gen() ai = me.__aiter__() an = ai.__anext__() with self.assertRaisesRegex(RuntimeError, r'anext\(\): asynchronous generator is already running'): an.__next__() with self.assertRaisesRegex(RuntimeError, r"cannot reuse already awaited __anext__\(\)/asend\(\)"): an.send(None) def test_async_gen_asend_throw_concurrent_with_send(self): import types @types.coroutine def _async_yield(v): return (yield v) class MyExc(Exception): pass async def agenfn(): while True: try: await _async_yield(None) except MyExc: pass return yield agen = agenfn() gen = agen.asend(None) gen.send(None) gen2 = agen.asend(None) with self.assertRaisesRegex(RuntimeError, r'anext\(\): asynchronous generator is already running'): gen2.throw(MyExc) with self.assertRaisesRegex(RuntimeError, r"cannot reuse already awaited __anext__\(\)/asend\(\)"): gen2.send(None) def test_async_gen_athrow_throw_concurrent_with_send(self): import types @types.coroutine def _async_yield(v): return (yield v) class MyExc(Exception): pass async def agenfn(): while True: try: await _async_yield(None) except MyExc: pass return yield agen = agenfn() gen = agen.asend(None) gen.send(None) gen2 = agen.athrow(MyExc) with self.assertRaisesRegex(RuntimeError, r'athrow\(\): asynchronous generator is already running'): gen2.throw(MyExc) with self.assertRaisesRegex(RuntimeError, r"cannot reuse already awaited aclose\(\)/athrow\(\)"): gen2.send(None) def test_async_gen_asend_throw_concurrent_with_throw(self): import types @types.coroutine def _async_yield(v): return (yield v) class MyExc(Exception): pass async def agenfn(): try: yield except MyExc: pass while True: try: await _async_yield(None) except MyExc: pass agen = agenfn() with self.assertRaises(StopIteration): agen.asend(None).send(None) gen = agen.athrow(MyExc) gen.throw(MyExc) gen2 = agen.asend(MyExc) with self.assertRaisesRegex(RuntimeError, r'anext\(\): asynchronous generator is already running'): gen2.throw(MyExc) with self.assertRaisesRegex(RuntimeError, r"cannot reuse already awaited __anext__\(\)/asend\(\)"): gen2.send(None) def test_async_gen_athrow_throw_concurrent_with_throw(self): import types @types.coroutine def _async_yield(v): return (yield v) class MyExc(Exception): pass async def agenfn(): try: yield except MyExc: pass while True: try: await _async_yield(None) except MyExc: pass agen = agenfn() with self.assertRaises(StopIteration): agen.asend(None).send(None) gen = agen.athrow(MyExc) gen.throw(MyExc) gen2 = agen.athrow(None) with self.assertRaisesRegex(RuntimeError, r'athrow\(\): asynchronous generator is already running'): gen2.throw(MyExc) with self.assertRaisesRegex(RuntimeError, r"cannot reuse already awaited aclose\(\)/athrow\(\)"): gen2.send(None) def test_async_gen_3_arg_deprecation_warning(self): async def gen(): yield 123 with self.assertWarns(DeprecationWarning): x = gen().athrow(GeneratorExit, GeneratorExit(), None) with self.assertRaises(GeneratorExit): x.send(None) del x gc_collect() def test_async_gen_api_01(self): async def gen(): yield 123 g = gen() self.assertEqual(g.__name__, 'gen') g.__name__ = '123' self.assertEqual(g.__name__, '123') self.assertIn('.gen', g.__qualname__) g.__qualname__ = '123' self.assertEqual(g.__qualname__, '123') self.assertIsNone(g.ag_await) self.assertIsInstance(g.ag_frame, types.FrameType) self.assertFalse(g.ag_running) self.assertIsInstance(g.ag_code, types.CodeType) aclose = g.aclose() self.assertTrue(inspect.isawaitable(aclose)) aclose.close() def test_async_gen_asend_close_runtime_error(self): import types @types.coroutine def _async_yield(v): return (yield v) async def agenfn(): try: await _async_yield(None) except GeneratorExit: await _async_yield(None) return yield agen = agenfn() gen = agen.asend(None) gen.send(None) with self.assertRaisesRegex(RuntimeError, "coroutine ignored GeneratorExit"): gen.close() def test_async_gen_athrow_close_runtime_error(self): import types @types.coroutine def _async_yield(v): return (yield v) class MyExc(Exception): pass async def agenfn(): try: yield except MyExc: try: await _async_yield(None) except GeneratorExit: await _async_yield(None) agen = agenfn() with self.assertRaises(StopIteration): agen.asend(None).send(None) gen = agen.athrow(MyExc) gen.send(None) with self.assertRaisesRegex(RuntimeError, "coroutine ignored GeneratorExit"): gen.close() class AsyncGenAsyncioTest(unittest.TestCase): def setUp(self): self.loop = asyncio.new_event_loop() asyncio.set_event_loop(None) def tearDown(self): self.loop.close() self.loop = None asyncio.set_event_loop_policy(None) def check_async_iterator_anext(self, ait_class): with self.subTest(anext="pure-Python"): self._check_async_iterator_anext(ait_class, py_anext) with self.subTest(anext="builtin"): self._check_async_iterator_anext(ait_class, anext) def _check_async_iterator_anext(self, ait_class, anext): g = ait_class() async def consume(): results = [] results.append(await anext(g)) results.append(await anext(g)) results.append(await anext(g, 'buckle my shoe')) return results res = self.loop.run_until_complete(consume()) self.assertEqual(res, [1, 2, 'buckle my shoe']) with self.assertRaises(StopAsyncIteration): self.loop.run_until_complete(consume()) async def test_2(): g1 = ait_class() self.assertEqual(await anext(g1), 1) self.assertEqual(await anext(g1), 2) with self.assertRaises(StopAsyncIteration): await anext(g1) with self.assertRaises(StopAsyncIteration): await anext(g1) g2 = ait_class() self.assertEqual(await anext(g2, "default"), 1) self.assertEqual(await anext(g2, "default"), 2) self.assertEqual(await anext(g2, "default"), "default") self.assertEqual(await anext(g2, "default"), "default") return "completed" result = self.loop.run_until_complete(test_2()) self.assertEqual(result, "completed") def test_send(): p = ait_class() obj = anext(p, "completed") with self.assertRaises(StopIteration): with contextlib.closing(obj.__await__()) as g: g.send(None) test_send() async def test_throw(): p = ait_class() obj = anext(p, "completed") self.assertRaises(SyntaxError, obj.throw, SyntaxError) return "completed" result = self.loop.run_until_complete(test_throw()) self.assertEqual(result, "completed") def test_async_generator_anext(self): async def agen(): yield 1 yield 2 self.check_async_iterator_anext(agen) def test_python_async_iterator_anext(self): class MyAsyncIter: """Asynchronously yield 1, then 2.""" def __init__(self): self.yielded = 0 def __aiter__(self): return self async def __anext__(self): if self.yielded >= 2: raise StopAsyncIteration() else: self.yielded += 1 return self.yielded self.check_async_iterator_anext(MyAsyncIter) def test_python_async_iterator_types_coroutine_anext(self): import types class MyAsyncIterWithTypesCoro: """Asynchronously yield 1, then 2.""" def __init__(self): self.yielded = 0 def __aiter__(self): return self @types.coroutine def __anext__(self): if False: yield "this is a generator-based coroutine" if self.yielded >= 2: raise StopAsyncIteration() else: self.yielded += 1 return self.yielded self.check_async_iterator_anext(MyAsyncIterWithTypesCoro) def test_async_gen_aiter(self): async def gen(): yield 1 yield 2 g = gen() async def consume(): return [i async for i in aiter(g)] res = self.loop.run_until_complete(consume()) self.assertEqual(res, [1, 2]) def test_async_gen_aiter_class(self): results = [] class Gen: async def __aiter__(self): yield 1 yield 2 g = Gen() async def consume(): ait = aiter(g) while True: try: results.append(await anext(ait)) except StopAsyncIteration: break self.loop.run_until_complete(consume()) self.assertEqual(results, [1, 2]) def test_aiter_idempotent(self): async def gen(): yield 1 applied_once = aiter(gen()) applied_twice = aiter(applied_once) self.assertIs(applied_once, applied_twice) def test_anext_bad_args(self): async def gen(): yield 1 async def call_with_too_few_args(): await anext() async def call_with_too_many_args(): await anext(gen(), 1, 3) async def call_with_wrong_type_args(): await anext(1, gen()) async def call_with_kwarg(): await anext(aiterator=gen()) with self.assertRaises(TypeError): self.loop.run_until_complete(call_with_too_few_args()) with self.assertRaises(TypeError): self.loop.run_until_complete(call_with_too_many_args()) with self.assertRaises(TypeError): self.loop.run_until_complete(call_with_wrong_type_args()) with self.assertRaises(TypeError): self.loop.run_until_complete(call_with_kwarg()) def test_anext_bad_await(self): async def bad_awaitable(): class BadAwaitable: def __await__(self): return 42 class MyAsyncIter: def __aiter__(self): return self def __anext__(self): return BadAwaitable() regex = r"__await__.*iterator" awaitable = anext(MyAsyncIter(), "default") with self.assertRaisesRegex(TypeError, regex): await awaitable awaitable = anext(MyAsyncIter()) with self.assertRaisesRegex(TypeError, regex): await awaitable return "completed" result = self.loop.run_until_complete(bad_awaitable()) self.assertEqual(result, "completed") async def check_anext_returning_iterator(self, aiter_class): awaitable = anext(aiter_class(), "default") with self.assertRaises(TypeError): await awaitable awaitable = anext(aiter_class()) with self.assertRaises(TypeError): await awaitable return "completed" def test_anext_return_iterator(self): class WithIterAnext: def __aiter__(self): return self def __anext__(self): return iter("abc") result = self.loop.run_until_complete(self.check_anext_returning_iterator(WithIterAnext)) self.assertEqual(result, "completed") def test_anext_return_generator(self): class WithGenAnext: def __aiter__(self): return self def __anext__(self): yield result = self.loop.run_until_complete(self.check_anext_returning_iterator(WithGenAnext)) self.assertEqual(result, "completed") def test_anext_await_raises(self): class RaisingAwaitable: def __await__(self): raise ZeroDivisionError() yield class WithRaisingAwaitableAnext: def __aiter__(self): return self def __anext__(self): return RaisingAwaitable() async def do_test(): awaitable = anext(WithRaisingAwaitableAnext()) with self.assertRaises(ZeroDivisionError): await awaitable awaitable = anext(WithRaisingAwaitableAnext(), "default") with self.assertRaises(ZeroDivisionError): await awaitable return "completed" result = self.loop.run_until_complete(do_test()) self.assertEqual(result, "completed") def test_anext_iter(self): @types.coroutine def _async_yield(v): return (yield v) class MyError(Exception): pass async def agenfn(): try: await _async_yield(1) except MyError: await _async_yield(2) return yield def test1(anext): agen = agenfn() with contextlib.closing(anext(agen, "default").__await__()) as g: self.assertEqual(g.send(None), 1) self.assertEqual(g.throw(MyError()), 2) try: g.send(None) except StopIteration as e: err = e else: self.fail('StopIteration was not raised') self.assertEqual(err.value, "default") def test2(anext): agen = agenfn() with contextlib.closing(anext(agen, "default").__await__()) as g: self.assertEqual(g.send(None), 1) self.assertEqual(g.throw(MyError()), 2) with self.assertRaises(MyError): g.throw(MyError()) def test3(anext): agen = agenfn() with contextlib.closing(anext(agen, "default").__await__()) as g: self.assertEqual(g.send(None), 1) g.close() with self.assertRaisesRegex(RuntimeError, 'cannot reuse'): self.assertEqual(g.send(None), 1) def test4(anext): @types.coroutine def _async_yield(v): yield v * 10 return (yield (v * 10 + 1)) async def agenfn(): try: await _async_yield(1) except MyError: await _async_yield(2) return yield agen = agenfn() with contextlib.closing(anext(agen, "default").__await__()) as g: self.assertEqual(g.send(None), 10) self.assertEqual(g.throw(MyError()), 20) with self.assertRaisesRegex(MyError, 'val'): g.throw(MyError('val')) def test5(anext): @types.coroutine def _async_yield(v): yield v * 10 return (yield (v * 10 + 1)) async def agenfn(): try: await _async_yield(1) except MyError: return yield 'aaa' agen = agenfn() with contextlib.closing(anext(agen, "default").__await__()) as g: self.assertEqual(g.send(None), 10) with self.assertRaisesRegex(StopIteration, 'default'): g.throw(MyError()) def test6(anext): @types.coroutine def _async_yield(v): yield v * 10 return (yield (v * 10 + 1)) async def agenfn(): await _async_yield(1) yield 'aaa' agen = agenfn() with contextlib.closing(anext(agen, "default").__await__()) as g: with self.assertRaises(MyError): g.throw(MyError()) def run_test(test): with self.subTest('pure-Python anext()'): test(py_anext) with self.subTest('builtin anext()'): test(anext) run_test(test1) run_test(test2) run_test(test3) run_test(test4) run_test(test5) run_test(test6) def test_aiter_bad_args(self): async def gen(): yield 1 async def call_with_too_few_args(): await aiter() async def call_with_too_many_args(): await aiter(gen(), 1) async def call_with_wrong_type_arg(): await aiter(1) with self.assertRaises(TypeError): self.loop.run_until_complete(call_with_too_few_args()) with self.assertRaises(TypeError): self.loop.run_until_complete(call_with_too_many_args()) with self.assertRaises(TypeError): self.loop.run_until_complete(call_with_wrong_type_arg()) async def to_list(self, gen): res = [] async for i in gen: res.append(i) return res def test_async_gen_asyncio_01(self): async def gen(): yield 1 await asyncio.sleep(0.01) yield 2 await asyncio.sleep(0.01) return yield 3 res = self.loop.run_until_complete(self.to_list(gen())) self.assertEqual(res, [1, 2]) def test_async_gen_asyncio_02(self): async def gen(): yield 1 await asyncio.sleep(0.01) yield 2 1 / 0 yield 3 with self.assertRaises(ZeroDivisionError): self.loop.run_until_complete(self.to_list(gen())) def test_async_gen_asyncio_03(self): loop = self.loop class Gen: async def __aiter__(self): yield 1 await asyncio.sleep(0.01) yield 2 res = loop.run_until_complete(self.to_list(Gen())) self.assertEqual(res, [1, 2]) def test_async_gen_asyncio_anext_04(self): async def foo(): yield 1 await asyncio.sleep(0.01) try: yield 2 yield 3 except ZeroDivisionError: yield 1000 await asyncio.sleep(0.01) yield 4 async def run1(): it = foo().__aiter__() self.assertEqual(await it.__anext__(), 1) self.assertEqual(await it.__anext__(), 2) self.assertEqual(await it.__anext__(), 3) self.assertEqual(await it.__anext__(), 4) with self.assertRaises(StopAsyncIteration): await it.__anext__() with self.assertRaises(StopAsyncIteration): await it.__anext__() async def run2(): it = foo().__aiter__() self.assertEqual(await it.__anext__(), 1) self.assertEqual(await it.__anext__(), 2) try: it.__anext__().throw(ZeroDivisionError) except StopIteration as ex: self.assertEqual(ex.args[0], 1000) else: self.fail('StopIteration was not raised') self.assertEqual(await it.__anext__(), 4) with self.assertRaises(StopAsyncIteration): await it.__anext__() self.loop.run_until_complete(run1()) self.loop.run_until_complete(run2()) def test_async_gen_asyncio_anext_05(self): async def foo(): v = yield 1 v = yield v yield v * 100 async def run(): it = foo().__aiter__() try: it.__anext__().send(None) except StopIteration as ex: self.assertEqual(ex.args[0], 1) else: self.fail('StopIteration was not raised') try: it.__anext__().send(10) except StopIteration as ex: self.assertEqual(ex.args[0], 10) else: self.fail('StopIteration was not raised') try: it.__anext__().send(12) except StopIteration as ex: self.assertEqual(ex.args[0], 1200) else: self.fail('StopIteration was not raised') with self.assertRaises(StopAsyncIteration): await it.__anext__() self.loop.run_until_complete(run()) def test_async_gen_asyncio_anext_06(self): DONE = 0 # test synchronous generators def foo(): try: yield except: pass g = foo() g.send(None) with self.assertRaises(StopIteration): g.send(None) # now with asynchronous generators async def gen(): nonlocal DONE try: yield except: pass DONE = 1 async def run(): nonlocal DONE g = gen() await g.asend(None) with self.assertRaises(StopAsyncIteration): await g.asend(None) DONE += 10 self.loop.run_until_complete(run()) self.assertEqual(DONE, 11) def test_async_gen_asyncio_anext_tuple(self): async def foo(): try: yield (1,) except ZeroDivisionError: yield (2,) async def run(): it = foo().__aiter__() self.assertEqual(await it.__anext__(), (1,)) with self.assertRaises(StopIteration) as cm: it.__anext__().throw(ZeroDivisionError) self.assertEqual(cm.exception.args[0], (2,)) with self.assertRaises(StopAsyncIteration): await it.__anext__() self.loop.run_until_complete(run()) def test_async_gen_asyncio_anext_tuple_no_exceptions(self): # StopAsyncIteration exceptions should be cleared. # See: https://github.com/python/cpython/issues/128078. async def foo(): if False: yield (1, 2) async def run(): it = foo().__aiter__() with self.assertRaises(StopAsyncIteration): await it.__anext__() res = await anext(it, ('a', 'b')) self.assertTupleEqual(res, ('a', 'b')) self.loop.run_until_complete(run()) def test_sync_anext_raises_exception(self): # See: https://github.com/python/cpython/issues/131670 msg = 'custom' for exc_type in [ StopAsyncIteration, StopIteration, ValueError, Exception, ]: exc = exc_type(msg) with self.subTest(exc=exc): class A: def __anext__(self): raise exc with self.assertRaisesRegex(exc_type, msg): anext(A()) with self.assertRaisesRegex(exc_type, msg): anext(A(), 1) def test_async_gen_asyncio_anext_stopiteration(self): async def foo(): try: yield StopIteration(1) except ZeroDivisionError: yield StopIteration(3) async def run(): it = foo().__aiter__() v = await it.__anext__() self.assertIsInstance(v, StopIteration) self.assertEqual(v.value, 1) with self.assertRaises(StopIteration) as cm: it.__anext__().throw(ZeroDivisionError) v = cm.exception.args[0] self.assertIsInstance(v, StopIteration) self.assertEqual(v.value, 3) with self.assertRaises(StopAsyncIteration): await it.__anext__() self.loop.run_until_complete(run()) def test_async_gen_asyncio_aclose_06(self): async def foo(): try: yield 1 1 / 0 finally: await asyncio.sleep(0.01) yield 12 async def run(): gen = foo() it = gen.__aiter__() await it.__anext__() await gen.aclose() with self.assertRaisesRegex( RuntimeError, "async generator ignored GeneratorExit"): self.loop.run_until_complete(run()) def test_async_gen_asyncio_aclose_07(self): DONE = 0 async def foo(): nonlocal DONE try: yield 1 1 / 0 finally: await asyncio.sleep(0.01) await asyncio.sleep(0.01) DONE += 1 DONE += 1000 async def run(): gen = foo() it = gen.__aiter__() await it.__anext__() await gen.aclose() self.loop.run_until_complete(run()) self.assertEqual(DONE, 1) def test_async_gen_asyncio_aclose_08(self): DONE = 0 fut = asyncio.Future(loop=self.loop) async def foo(): nonlocal DONE try: yield 1 await fut DONE += 1000 yield 2 finally: await asyncio.sleep(0.01) await asyncio.sleep(0.01) DONE += 1 DONE += 1000 async def run(): gen = foo() it = gen.__aiter__() self.assertEqual(await it.__anext__(), 1) await gen.aclose() self.loop.run_until_complete(run()) self.assertEqual(DONE, 1) # Silence ResourceWarnings fut.cancel() self.loop.run_until_complete(asyncio.sleep(0.01)) def test_async_gen_asyncio_gc_aclose_09(self): DONE = 0 async def gen(): nonlocal DONE try: while True: yield 1 finally: await asyncio.sleep(0) DONE = 1 async def run(): g = gen() await g.__anext__() await g.__anext__() del g gc_collect() # For PyPy or other GCs. # Starts running the aclose task await asyncio.sleep(0) # For asyncio.sleep(0) in finally block await asyncio.sleep(0) self.loop.run_until_complete(run()) self.assertEqual(DONE, 1) def test_async_gen_asyncio_aclose_10(self): DONE = 0 # test synchronous generators def foo(): try: yield except: pass g = foo() g.send(None) g.close() # now with asynchronous generators async def gen(): nonlocal DONE try: yield except: pass DONE = 1 async def run(): nonlocal DONE g = gen() await g.asend(None) await g.aclose() DONE += 10 self.loop.run_until_complete(run()) self.assertEqual(DONE, 11) def test_async_gen_asyncio_aclose_11(self): DONE = 0 # test synchronous generators def foo(): try: yield except: pass yield g = foo() g.send(None) with self.assertRaisesRegex(RuntimeError, 'ignored GeneratorExit'): g.close() # now with asynchronous generators async def gen(): nonlocal DONE try: yield except: pass yield DONE += 1 async def run(): nonlocal DONE g = gen() await g.asend(None) with self.assertRaisesRegex(RuntimeError, 'ignored GeneratorExit'): await g.aclose() DONE += 10 self.loop.run_until_complete(run()) self.assertEqual(DONE, 10) def test_async_gen_asyncio_aclose_12(self): DONE = 0 async def target(): await asyncio.sleep(0.01) 1 / 0 async def foo(): nonlocal DONE task = asyncio.create_task(target()) try: yield 1 finally: try: await task except ZeroDivisionError: DONE = 1 async def run(): gen = foo() it = gen.__aiter__() await it.__anext__() await gen.aclose() self.loop.run_until_complete(run()) self.assertEqual(DONE, 1) def test_async_gen_asyncio_asend_01(self): DONE = 0 # Sanity check: def sgen(): v = yield 1 yield v * 2 sg = sgen() v = sg.send(None) self.assertEqual(v, 1) v = sg.send(100) self.assertEqual(v, 200) async def gen(): nonlocal DONE try: await asyncio.sleep(0.01) v = yield 1 await asyncio.sleep(0.01) yield v * 2 await asyncio.sleep(0.01) return finally: await asyncio.sleep(0.01) await asyncio.sleep(0.01) DONE = 1 async def run(): g = gen() v = await g.asend(None) self.assertEqual(v, 1) v = await g.asend(100) self.assertEqual(v, 200) with self.assertRaises(StopAsyncIteration): await g.asend(None) self.loop.run_until_complete(run()) self.assertEqual(DONE, 1) def test_async_gen_asyncio_asend_02(self): DONE = 0 async def sleep_n_crash(delay): await asyncio.sleep(delay) 1 / 0 async def gen(): nonlocal DONE try: await asyncio.sleep(0.01) v = yield 1 await sleep_n_crash(0.01) DONE += 1000 yield v * 2 finally: await asyncio.sleep(0.01) await asyncio.sleep(0.01) DONE = 1 async def run(): g = gen() v = await g.asend(None) self.assertEqual(v, 1) await g.asend(100) with self.assertRaises(ZeroDivisionError): self.loop.run_until_complete(run()) self.assertEqual(DONE, 1) def test_async_gen_asyncio_asend_03(self): DONE = 0 async def sleep_n_crash(delay): fut = asyncio.ensure_future(asyncio.sleep(delay), loop=self.loop) self.loop.call_later(delay / 2, lambda: fut.cancel()) return await fut async def gen(): nonlocal DONE try: await asyncio.sleep(0.01) v = yield 1 await sleep_n_crash(0.01) DONE += 1000 yield v * 2 finally: await asyncio.sleep(0.01) await asyncio.sleep(0.01) DONE = 1 async def run(): g = gen() v = await g.asend(None) self.assertEqual(v, 1) await g.asend(100) with self.assertRaises(asyncio.CancelledError): self.loop.run_until_complete(run()) self.assertEqual(DONE, 1) def test_async_gen_asyncio_athrow_01(self): DONE = 0 class FooEr(Exception): pass # Sanity check: def sgen(): try: v = yield 1 except FooEr: v = 1000 yield v * 2 sg = sgen() v = sg.send(None) self.assertEqual(v, 1) v = sg.throw(FooEr) self.assertEqual(v, 2000) with self.assertRaises(StopIteration): sg.send(None) async def gen(): nonlocal DONE try: await asyncio.sleep(0.01) try: v = yield 1 except FooEr: v = 1000 await asyncio.sleep(0.01) yield v * 2 await asyncio.sleep(0.01) # return finally: await asyncio.sleep(0.01) await asyncio.sleep(0.01) DONE = 1 async def run(): g = gen() v = await g.asend(None) self.assertEqual(v, 1) v = await g.athrow(FooEr) self.assertEqual(v, 2000) with self.assertRaises(StopAsyncIteration): await g.asend(None) self.loop.run_until_complete(run()) self.assertEqual(DONE, 1) def test_async_gen_asyncio_athrow_02(self): DONE = 0 class FooEr(Exception): pass async def sleep_n_crash(delay): fut = asyncio.ensure_future(asyncio.sleep(delay), loop=self.loop) self.loop.call_later(delay / 2, lambda: fut.cancel()) return await fut async def gen(): nonlocal DONE try: await asyncio.sleep(0.01) try: v = yield 1 except FooEr: await sleep_n_crash(0.01) yield v * 2 await asyncio.sleep(0.01) # return finally: await asyncio.sleep(0.01) await asyncio.sleep(0.01) DONE = 1 async def run(): g = gen() v = await g.asend(None) self.assertEqual(v, 1) try: await g.athrow(FooEr) except asyncio.CancelledError: self.assertEqual(DONE, 1) raise else: self.fail('CancelledError was not raised') with self.assertRaises(asyncio.CancelledError): self.loop.run_until_complete(run()) self.assertEqual(DONE, 1) def test_async_gen_asyncio_athrow_03(self): DONE = 0 # test synchronous generators def foo(): try: yield except: pass g = foo() g.send(None) with self.assertRaises(StopIteration): g.throw(ValueError) # now with asynchronous generators async def gen(): nonlocal DONE try: yield except: pass DONE = 1 async def run(): nonlocal DONE g = gen() await g.asend(None) with self.assertRaises(StopAsyncIteration): await g.athrow(ValueError) DONE += 10 self.loop.run_until_complete(run()) self.assertEqual(DONE, 11) def test_async_gen_asyncio_athrow_tuple(self): async def gen(): try: yield 1 except ZeroDivisionError: yield (2,) async def run(): g = gen() v = await g.asend(None) self.assertEqual(v, 1) v = await g.athrow(ZeroDivisionError) self.assertEqual(v, (2,)) with self.assertRaises(StopAsyncIteration): await g.asend(None) self.loop.run_until_complete(run()) def test_async_gen_asyncio_athrow_stopiteration(self): async def gen(): try: yield 1 except ZeroDivisionError: yield StopIteration(2) async def run(): g = gen() v = await g.asend(None) self.assertEqual(v, 1) v = await g.athrow(ZeroDivisionError) self.assertIsInstance(v, StopIteration) self.assertEqual(v.value, 2) with self.assertRaises(StopAsyncIteration): await g.asend(None) self.loop.run_until_complete(run()) def test_async_gen_asyncio_shutdown_01(self): finalized = 0 async def waiter(timeout): nonlocal finalized try: await asyncio.sleep(timeout) yield 1 finally: await asyncio.sleep(0) finalized += 1 async def wait(): async for _ in waiter(1): pass t1 = self.loop.create_task(wait()) t2 = self.loop.create_task(wait()) self.loop.run_until_complete(asyncio.sleep(0.1)) # Silence warnings t1.cancel() t2.cancel() with self.assertRaises(asyncio.CancelledError): self.loop.run_until_complete(t1) with self.assertRaises(asyncio.CancelledError): self.loop.run_until_complete(t2) self.loop.run_until_complete(self.loop.shutdown_asyncgens()) self.assertEqual(finalized, 2) def test_async_gen_asyncio_shutdown_02(self): messages = [] def exception_handler(loop, context): messages.append(context) async def async_iterate(): yield 1 yield 2 it = async_iterate() async def main(): loop = asyncio.get_running_loop() loop.set_exception_handler(exception_handler) async for i in it: break asyncio.run(main()) self.assertEqual(messages, []) def test_async_gen_asyncio_shutdown_exception_01(self): messages = [] def exception_handler(loop, context): messages.append(context) async def async_iterate(): try: yield 1 yield 2 finally: 1/0 it = async_iterate() async def main(): loop = asyncio.get_running_loop() loop.set_exception_handler(exception_handler) async for i in it: break asyncio.run(main()) message, = messages self.assertEqual(message['asyncgen'], it) self.assertIsInstance(message['exception'], ZeroDivisionError) self.assertIn('an error occurred during closing of asynchronous generator', message['message']) def test_async_gen_asyncio_shutdown_exception_02(self): messages = [] def exception_handler(loop, context): messages.append(context) async def async_iterate(): try: yield 1 yield 2 finally: 1/0 async def main(): loop = asyncio.get_running_loop() loop.set_exception_handler(exception_handler) async for i in async_iterate(): break gc_collect() asyncio.run(main()) message, = messages self.assertIsInstance(message['exception'], ZeroDivisionError) self.assertIn('unhandled exception during asyncio.run() shutdown', message['message']) del message, messages gc_collect() def test_async_gen_expression_01(self): async def arange(n): for i in range(n): await asyncio.sleep(0.01) yield i def make_arange(n): # This syntax is legal starting with Python 3.7 return (i * 2 async for i in arange(n)) async def run(): return [i async for i in make_arange(10)] res = self.loop.run_until_complete(run()) self.assertEqual(res, [i * 2 for i in range(10)]) def test_async_gen_expression_02(self): async def wrap(n): await asyncio.sleep(0.01) return n def make_arange(n): # This syntax is legal starting with Python 3.7 return (i * 2 for i in range(n) if await wrap(i)) async def run(): return [i async for i in make_arange(10)] res = self.loop.run_until_complete(run()) self.assertEqual(res, [i * 2 for i in range(1, 10)]) def test_asyncgen_nonstarted_hooks_are_cancellable(self): # See https://bugs.python.org/issue38013 messages = [] def exception_handler(loop, context): messages.append(context) async def async_iterate(): yield 1 yield 2 async def main(): loop = asyncio.get_running_loop() loop.set_exception_handler(exception_handler) async for i in async_iterate(): break asyncio.run(main()) self.assertEqual([], messages) gc_collect() def test_async_gen_await_same_anext_coro_twice(self): async def async_iterate(): yield 1 yield 2 async def run(): it = async_iterate() nxt = it.__anext__() await nxt with self.assertRaisesRegex( RuntimeError, r"cannot reuse already awaited __anext__\(\)/asend\(\)" ): await nxt await it.aclose() # prevent unfinished iterator warning self.loop.run_until_complete(run()) def test_async_gen_await_same_aclose_coro_twice(self): async def async_iterate(): yield 1 yield 2 async def run(): it = async_iterate() nxt = it.aclose() await nxt with self.assertRaisesRegex( RuntimeError, r"cannot reuse already awaited aclose\(\)/athrow\(\)" ): await nxt self.loop.run_until_complete(run()) def test_async_gen_throw_same_aclose_coro_twice(self): async def async_iterate(): yield 1 yield 2 it = async_iterate() nxt = it.aclose() with self.assertRaises(StopIteration): nxt.throw(GeneratorExit) with self.assertRaisesRegex( RuntimeError, r"cannot reuse already awaited aclose\(\)/athrow\(\)" ): nxt.throw(GeneratorExit) def test_async_gen_throw_custom_same_aclose_coro_twice(self): async def async_iterate(): yield 1 yield 2 it = async_iterate() class MyException(Exception): pass nxt = it.aclose() with self.assertRaises(MyException): nxt.throw(MyException) with self.assertRaisesRegex( RuntimeError, r"cannot reuse already awaited aclose\(\)/athrow\(\)" ): nxt.throw(MyException) def test_async_gen_throw_custom_same_athrow_coro_twice(self): async def async_iterate(): yield 1 yield 2 it = async_iterate() class MyException(Exception): pass nxt = it.athrow(MyException) with self.assertRaises(MyException): nxt.throw(MyException) with self.assertRaisesRegex( RuntimeError, r"cannot reuse already awaited aclose\(\)/athrow\(\)" ): nxt.throw(MyException) def test_async_gen_aclose_twice_with_different_coros(self): # Regression test for https://bugs.python.org/issue39606 async def async_iterate(): yield 1 yield 2 async def run(): it = async_iterate() await it.aclose() await it.aclose() self.loop.run_until_complete(run()) def test_async_gen_aclose_after_exhaustion(self): # Regression test for https://bugs.python.org/issue39606 async def async_iterate(): yield 1 yield 2 async def run(): it = async_iterate() async for _ in it: pass await it.aclose() self.loop.run_until_complete(run()) def test_async_gen_aclose_compatible_with_get_stack(self): async def async_generator(): yield object() async def run(): ag = async_generator() asyncio.create_task(ag.aclose()) tasks = asyncio.all_tasks() for task in tasks: # No AttributeError raised task.get_stack() self.loop.run_until_complete(run()) class TestUnawaitedWarnings(unittest.TestCase): def test_asend(self): async def gen(): yield 1 # gh-113753: asend objects allocated from a free-list should warn. # Ensure there is a finalized 'asend' object ready to be reused. try: g = gen() g.asend(None).send(None) except StopIteration: pass msg = f"coroutine method 'asend' of '{gen.__qualname__}' was never awaited" with self.assertWarnsRegex(RuntimeWarning, msg): g = gen() g.asend(None) gc_collect() def test_athrow(self): async def gen(): yield 1 msg = f"coroutine method 'athrow' of '{gen.__qualname__}' was never awaited" with self.assertWarnsRegex(RuntimeWarning, msg): g = gen() g.athrow(RuntimeError) gc_collect() def test_aclose(self): async def gen(): yield 1 msg = f"coroutine method 'aclose' of '{gen.__qualname__}' was never awaited" with self.assertWarnsRegex(RuntimeWarning, msg): g = gen() g.aclose() gc_collect() def test_aclose_throw(self): async def gen(): return yield class MyException(Exception): pass g = gen() with self.assertRaises(MyException): g.aclose().throw(MyException) del g gc_collect() # does not warn unawaited def test_asend_send_already_running(self): @types.coroutine def _async_yield(v): return (yield v) async def agenfn(): while True: await _async_yield(1) return yield agen = agenfn() gen = agen.asend(None) gen.send(None) gen2 = agen.asend(None) with self.assertRaisesRegex(RuntimeError, r'anext\(\): asynchronous generator is already running'): gen2.send(None) del gen2 gc_collect() # does not warn unawaited def test_athrow_send_already_running(self): @types.coroutine def _async_yield(v): return (yield v) async def agenfn(): while True: await _async_yield(1) return yield agen = agenfn() gen = agen.asend(None) gen.send(None) gen2 = agen.athrow(Exception) with self.assertRaisesRegex(RuntimeError, r'athrow\(\): asynchronous generator is already running'): gen2.send(None) del gen2 gc_collect() # does not warn unawaited if __name__ == "__main__": unittest.main()