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.217.130
Domains :
Cant Read [ /etc/named.conf ]
User : beriska1
Terminal
Auto Root
Create File
Create Folder
Localroot Suggester
Backdoor Destroyer
Readme
/
opt /
alt /
python312 /
lib64 /
python3.12 /
test /
Delete
Unzip
Name
Size
Permission
Date
Action
__pycache__
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
audiodata
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
certdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
cjkencodings
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
configdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
crashers
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
data
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
decimaltestdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
dtracedata
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
encoded_modules
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
imghdrdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
leakers
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
libregrtest
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
regrtestdata
[ DIR ]
drwxr-xr-x
2026-04-20 11:15
sndhdrdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
subprocessdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
support
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_ast
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_asyncio
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_capi
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_cext
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_concurrent_futures
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_cppext
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_ctypes
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_dataclasses
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_doctest
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_email
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_future_stmt
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_gdb
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_import
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_importlib
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_inspect
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_json
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_lib2to3
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_module
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_multiprocessing_fork
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_multiprocessing_forkserver
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_multiprocessing_spawn
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_peg_generator
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_pydoc
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_sqlite3
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_tkinter
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_tomllib
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_tools
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_ttk
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_unittest
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_warnings
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_zipfile
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
test_zoneinfo
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
tokenizedata
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
tracedmodules
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
translationdata
[ DIR ]
drwxr-xr-x
2026-04-20 11:15
typinganndata
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
wheeldata
[ DIR ]
drwxr-xr-x
2026-05-05 23:12
xmltestdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
ziptestdata
[ DIR ]
drwxr-xr-x
2026-05-05 23:07
Sine-1000Hz-300ms.aif
60.25
KB
-rw-r--r--
2026-03-03 16:09
__init__.py
47
B
-rw-r--r--
2026-04-20 11:09
__main__.py
67
B
-rw-r--r--
2026-04-20 11:09
_test_atexit.py
3.61
KB
-rw-r--r--
2026-04-20 11:09
_test_eintr.py
17.72
KB
-rw-r--r--
2026-04-20 11:09
_test_embed_set_config.py
8.64
KB
-rw-r--r--
2026-04-20 11:09
_test_embed_structseq.py
1.99
KB
-rw-r--r--
2026-04-20 11:09
_test_multiprocessing.py
216.26
KB
-rw-r--r--
2026-04-20 11:09
_test_venv_multiprocessing.py
796
B
-rw-r--r--
2026-04-20 11:09
archiver_tests.py
6.1
KB
-rw-r--r--
2026-04-20 11:09
audiotest.au
27.48
KB
-rw-r--r--
2026-03-03 16:09
audiotests.py
12.13
KB
-rw-r--r--
2026-04-20 11:09
audit-tests.py
13.76
KB
-rw-r--r--
2026-04-20 11:09
autotest.py
214
B
-rw-r--r--
2026-04-20 11:09
bisect_cmd.py
5.36
KB
-rwxr-xr-x
2026-04-20 11:09
clinic.test.c
139.1
KB
-rw-r--r--
2026-03-03 16:09
cmath_testcases.txt
141.2
KB
-rw-r--r--
2026-03-03 16:09
curses_tests.py
1.23
KB
-rwxr-xr-x
2026-04-20 11:09
datetimetester.py
265.73
KB
-rw-r--r--
2026-04-20 11:09
dis_module.py
76
B
-rw-r--r--
2026-04-20 11:09
empty.vbs
70
B
-rw-r--r--
2026-03-03 16:09
exception_hierarchy.txt
2.33
KB
-rw-r--r--
2026-03-03 16:09
floating_points.txt
15.92
KB
-rw-r--r--
2026-03-03 16:09
fork_wait.py
2.29
KB
-rw-r--r--
2026-04-20 11:09
formatfloat_testcases.txt
7.45
KB
-rw-r--r--
2026-03-03 16:09
ieee754.txt
3.15
KB
-rw-r--r--
2026-03-03 16:09
levenshtein_examples.json
406.44
KB
-rw-r--r--
2026-03-03 16:09
list_tests.py
16.9
KB
-rw-r--r--
2026-04-20 11:09
lock_tests.py
35.64
KB
-rw-r--r--
2026-04-20 11:09
mailcap.txt
1.24
KB
-rw-r--r--
2026-03-03 16:09
mapping_tests.py
21.87
KB
-rw-r--r--
2026-04-20 11:09
math_testcases.txt
23.19
KB
-rw-r--r--
2026-03-03 16:09
memory_watchdog.py
711
B
-rw-r--r--
2026-04-20 11:09
mime.types
47.37
KB
-rw-r--r--
2026-03-03 16:09
mock_socket.py
3.69
KB
-rw-r--r--
2026-04-20 11:09
mp_fork_bomb.py
448
B
-rw-r--r--
2026-04-20 11:09
mp_preload.py
351
B
-rw-r--r--
2026-04-20 11:09
multibytecodec_support.py
14.19
KB
-rw-r--r--
2026-04-20 11:09
pickletester.py
172.37
KB
-rw-r--r--
2026-04-20 11:09
profilee.py
2.97
KB
-rw-r--r--
2026-04-20 11:09
pstats.pck
65.05
KB
-rw-r--r--
2026-03-03 16:09
pyclbr_input.py
1.63
KB
-rw-r--r--
2026-04-20 11:09
pythoninfo.py
28.35
KB
-rw-r--r--
2026-04-20 11:09
randv2_32.pck
7.34
KB
-rw-r--r--
2026-03-03 16:09
randv2_64.pck
7.19
KB
-rw-r--r--
2026-03-03 16:09
randv3.pck
7.82
KB
-rw-r--r--
2026-03-03 16:09
re_tests.py
25.94
KB
-rwxr-xr-x
2026-04-20 11:09
recursion.tar
516
B
-rw-r--r--
2026-03-03 16:09
regrtest.py
1.28
KB
-rwxr-xr-x
2026-04-20 11:09
relimport.py
27
B
-rw-r--r--
2026-04-20 11:09
reperf.py
538
B
-rw-r--r--
2026-04-20 11:09
seq_tests.py
14.96
KB
-rw-r--r--
2026-04-20 11:09
signalinterproctester.py
3.12
KB
-rw-r--r--
2026-04-20 11:09
ssl_servers.py
7.12
KB
-rw-r--r--
2026-04-20 11:09
ssltests.py
1.03
KB
-rw-r--r--
2026-04-20 11:09
string_tests.py
71.24
KB
-rw-r--r--
2026-04-20 11:09
test___all__.py
5.04
KB
-rw-r--r--
2026-04-20 11:09
test__locale.py
12.52
KB
-rw-r--r--
2026-04-20 11:09
test__opcode.py
4.14
KB
-rw-r--r--
2026-04-20 11:09
test__osx_support.py
13.53
KB
-rw-r--r--
2026-04-20 11:09
test__xxinterpchannels.py
52.19
KB
-rw-r--r--
2026-04-20 11:09
test__xxsubinterpreters.py
27.5
KB
-rw-r--r--
2026-04-20 11:09
test_abc.py
23.81
KB
-rw-r--r--
2026-04-20 11:09
test_abstract_numbers.py
5.81
KB
-rw-r--r--
2026-04-20 11:09
test_aifc.py
17.84
KB
-rw-r--r--
2026-04-20 11:09
test_argparse.py
218.49
KB
-rw-r--r--
2026-04-20 11:09
test_array.py
55.44
KB
-rw-r--r--
2026-04-20 11:09
test_asdl_parser.py
4.44
KB
-rw-r--r--
2026-04-20 11:09
test_asyncgen.py
53.94
KB
-rw-r--r--
2026-04-20 11:09
test_atexit.py
3.2
KB
-rw-r--r--
2026-04-20 11:09
test_audioop.py
28.32
KB
-rw-r--r--
2026-04-20 11:09
test_audit.py
9.22
KB
-rw-r--r--
2026-04-20 11:09
test_augassign.py
7.68
KB
-rw-r--r--
2026-04-20 11:09
test_base64.py
35.05
KB
-rw-r--r--
2026-04-20 11:09
test_baseexception.py
7.77
KB
-rw-r--r--
2026-04-20 11:09
test_bdb.py
44.17
KB
-rw-r--r--
2026-04-20 11:09
test_bigaddrspace.py
2.83
KB
-rw-r--r--
2026-04-20 11:09
test_bigmem.py
45.01
KB
-rw-r--r--
2026-04-20 11:09
test_binascii.py
20.09
KB
-rw-r--r--
2026-04-20 11:09
test_binop.py
14.14
KB
-rw-r--r--
2026-04-20 11:09
test_bisect.py
16.63
KB
-rw-r--r--
2026-04-20 11:09
test_bool.py
14.25
KB
-rw-r--r--
2026-04-20 11:09
test_buffer.py
171.88
KB
-rw-r--r--
2026-04-20 11:09
test_bufio.py
2.56
KB
-rw-r--r--
2026-04-20 11:09
test_builtin.py
96.66
KB
-rw-r--r--
2026-04-20 11:09
test_bytes.py
82.01
KB
-rw-r--r--
2026-04-20 11:09
test_bz2.py
42.59
KB
-rw-r--r--
2026-04-20 11:09
test_c_locale_coercion.py
20.99
KB
-rw-r--r--
2026-04-20 11:09
test_calendar.py
51.78
KB
-rw-r--r--
2026-04-20 11:09
test_call.py
35.21
KB
-rw-r--r--
2026-04-20 11:09
test_cgi.py
22.27
KB
-rw-r--r--
2026-04-20 11:09
test_cgitb.py
2.62
KB
-rw-r--r--
2026-04-20 11:09
test_charmapcodec.py
1.77
KB
-rw-r--r--
2026-04-20 11:09
test_class.py
22.02
KB
-rw-r--r--
2026-04-20 11:09
test_clinic.py
85.41
KB
-rw-r--r--
2026-04-20 11:09
test_cmath.py
22.47
KB
-rw-r--r--
2026-04-20 11:09
test_cmd.py
6.49
KB
-rw-r--r--
2026-04-20 11:09
test_cmd_line.py
39.51
KB
-rw-r--r--
2026-04-20 11:09
test_cmd_line_script.py
34.93
KB
-rw-r--r--
2026-04-20 11:09
test_code.py
25.7
KB
-rw-r--r--
2026-04-20 11:09
test_code_module.py
12.73
KB
-rw-r--r--
2026-04-20 11:09
test_codeccallbacks.py
49.23
KB
-rw-r--r--
2026-04-20 11:09
test_codecencodings_cn.py
3.86
KB
-rw-r--r--
2026-04-20 11:09
test_codecencodings_hk.py
701
B
-rw-r--r--
2026-04-20 11:09
test_codecencodings_iso2022.py
3.65
KB
-rw-r--r--
2026-04-20 11:09
test_codecencodings_jp.py
4.79
KB
-rw-r--r--
2026-04-20 11:09
test_codecencodings_kr.py
2.96
KB
-rw-r--r--
2026-04-20 11:09
test_codecencodings_tw.py
681
B
-rw-r--r--
2026-04-20 11:09
test_codecmaps_cn.py
746
B
-rw-r--r--
2026-04-20 11:09
test_codecmaps_hk.py
386
B
-rw-r--r--
2026-04-20 11:09
test_codecmaps_jp.py
1.7
KB
-rw-r--r--
2026-04-20 11:09
test_codecmaps_kr.py
1.16
KB
-rw-r--r--
2026-04-20 11:09
test_codecmaps_tw.py
705
B
-rw-r--r--
2026-04-20 11:09
test_codecs.py
137.42
KB
-rw-r--r--
2026-04-20 11:09
test_codeop.py
8.68
KB
-rw-r--r--
2026-04-20 11:09
test_collections.py
93.47
KB
-rw-r--r--
2026-04-20 11:09
test_colorsys.py
4.27
KB
-rw-r--r--
2026-04-20 11:09
test_compare.py
17.46
KB
-rw-r--r--
2026-04-20 11:09
test_compile.py
81.24
KB
-rw-r--r--
2026-04-20 11:09
test_compileall.py
48.53
KB
-rw-r--r--
2026-04-20 11:09
test_compiler_assemble.py
2.46
KB
-rw-r--r--
2026-04-20 11:09
test_compiler_codegen.py
1.72
KB
-rw-r--r--
2026-04-20 11:09
test_complex.py
35.21
KB
-rw-r--r--
2026-04-20 11:09
test_configparser.py
85.34
KB
-rw-r--r--
2026-04-20 11:09
test_contains.py
3.35
KB
-rw-r--r--
2026-04-20 11:09
test_context.py
31.1
KB
-rw-r--r--
2026-04-20 11:09
test_contextlib.py
43.08
KB
-rw-r--r--
2026-04-20 11:09
test_contextlib_async.py
23.99
KB
-rw-r--r--
2026-04-20 11:09
test_copy.py
26.52
KB
-rw-r--r--
2026-04-20 11:09
test_copyreg.py
4.36
KB
-rw-r--r--
2026-04-20 11:09
test_coroutines.py
67.47
KB
-rw-r--r--
2026-04-20 11:09
test_cprofile.py
9.44
KB
-rw-r--r--
2026-04-20 11:09
test_crashers.py
1.17
KB
-rw-r--r--
2026-04-20 11:09
test_crypt.py
4.19
KB
-rw-r--r--
2026-04-20 11:09
test_csv.py
61.59
KB
-rw-r--r--
2026-04-20 11:09
test_curses.py
50.14
KB
-rw-r--r--
2026-04-20 11:09
test_datetime.py
2.67
KB
-rw-r--r--
2026-04-20 11:09
test_dbm.py
6.83
KB
-rw-r--r--
2026-04-20 11:09
test_dbm_dumb.py
11.08
KB
-rw-r--r--
2026-04-20 11:09
test_dbm_gnu.py
7.64
KB
-rw-r--r--
2026-04-20 11:09
test_dbm_ndbm.py
5.91
KB
-rw-r--r--
2026-04-20 11:09
test_decimal.py
217.94
KB
-rw-r--r--
2026-04-20 11:09
test_decorators.py
14.63
KB
-rw-r--r--
2026-04-20 11:09
test_defaultdict.py
6.1
KB
-rw-r--r--
2026-04-20 11:09
test_deque.py
33.16
KB
-rw-r--r--
2026-04-20 11:09
test_descr.py
196.2
KB
-rw-r--r--
2026-04-20 11:09
test_descrtut.py
10.98
KB
-rw-r--r--
2026-04-20 11:09
test_devpoll.py
4.44
KB
-rw-r--r--
2026-04-20 11:09
test_dict.py
51.33
KB
-rw-r--r--
2026-04-20 11:09
test_dict_version.py
6.1
KB
-rw-r--r--
2026-04-20 11:09
test_dictcomps.py
6.55
KB
-rw-r--r--
2026-04-20 11:09
test_dictviews.py
14.82
KB
-rw-r--r--
2026-04-20 11:09
test_difflib.py
21.47
KB
-rw-r--r--
2026-04-20 11:09
test_difflib_expect.html
100.9
KB
-rw-r--r--
2026-03-03 16:09
test_dis.py
83.45
KB
-rw-r--r--
2026-04-20 11:09
test_docxmlrpc.py
9.1
KB
-rw-r--r--
2026-04-20 11:09
test_dtrace.py
7.98
KB
-rw-r--r--
2026-04-20 11:09
test_dynamic.py
6
KB
-rw-r--r--
2026-04-20 11:09
test_dynamicclassattribute.py
9.57
KB
-rw-r--r--
2026-04-20 11:09
test_eintr.py
627
B
-rw-r--r--
2026-04-20 11:09
test_embed.py
69.88
KB
-rw-r--r--
2026-04-20 11:09
test_ensurepip.py
11.49
KB
-rw-r--r--
2026-04-20 11:09
test_enum.py
188.15
KB
-rw-r--r--
2026-04-20 11:09
test_enumerate.py
9.14
KB
-rw-r--r--
2026-04-20 11:09
test_eof.py
7.94
KB
-rw-r--r--
2026-04-20 11:09
test_epoll.py
9.4
KB
-rw-r--r--
2026-04-20 11:09
test_errno.py
1.04
KB
-rw-r--r--
2026-04-20 11:09
test_except_star.py
39.7
KB
-rw-r--r--
2026-04-20 11:09
test_exception_group.py
34.03
KB
-rw-r--r--
2026-04-20 11:09
test_exception_hierarchy.py
7.54
KB
-rw-r--r--
2026-04-20 11:09
test_exception_variations.py
13.74
KB
-rw-r--r--
2026-04-20 11:09
test_exceptions.py
83.63
KB
-rw-r--r--
2026-04-20 11:09
test_extcall.py
14.69
KB
-rw-r--r--
2026-04-20 11:09
test_faulthandler.py
30.31
KB
-rw-r--r--
2026-04-20 11:09
test_fcntl.py
7.76
KB
-rw-r--r--
2026-04-20 11:09
test_file.py
11.78
KB
-rw-r--r--
2026-04-20 11:09
test_file_eintr.py
10.74
KB
-rw-r--r--
2026-04-20 11:09
test_filecmp.py
11.98
KB
-rw-r--r--
2026-04-20 11:09
test_fileinput.py
37.86
KB
-rw-r--r--
2026-04-20 11:09
test_fileio.py
19.98
KB
-rw-r--r--
2026-04-20 11:09
test_fileutils.py
951
B
-rw-r--r--
2026-04-20 11:09
test_finalization.py
14.66
KB
-rw-r--r--
2026-04-20 11:09
test_float.py
64.65
KB
-rw-r--r--
2026-04-20 11:09
test_flufl.py
2.81
KB
-rw-r--r--
2026-04-20 11:09
test_fnmatch.py
10.68
KB
-rw-r--r--
2026-04-20 11:09
test_fork1.py
3.3
KB
-rw-r--r--
2026-04-20 11:09
test_format.py
28.44
KB
-rw-r--r--
2026-04-20 11:09
test_fractions.py
65.65
KB
-rw-r--r--
2026-04-20 11:09
test_frame.py
14.04
KB
-rw-r--r--
2026-04-20 11:09
test_frozen.py
2.2
KB
-rw-r--r--
2026-04-20 11:09
test_fstring.py
64.74
KB
-rw-r--r--
2026-04-20 11:09
test_ftplib.py
41.97
KB
-rw-r--r--
2026-04-20 11:09
test_funcattrs.py
15.71
KB
-rw-r--r--
2026-04-20 11:09
test_functools.py
114.02
KB
-rw-r--r--
2026-04-20 11:09
test_gc.py
47.71
KB
-rw-r--r--
2026-04-20 11:09
test_generator_stop.py
943
B
-rw-r--r--
2026-04-20 11:09
test_generators.py
66.48
KB
-rw-r--r--
2026-04-20 11:09
test_genericalias.py
17.78
KB
-rw-r--r--
2026-04-20 11:09
test_genericclass.py
9.44
KB
-rw-r--r--
2026-04-20 11:09
test_genericpath.py
23.25
KB
-rw-r--r--
2026-04-20 11:09
test_genexps.py
7.3
KB
-rw-r--r--
2026-04-20 11:09
test_getopt.py
6.94
KB
-rw-r--r--
2026-04-20 11:09
test_getpass.py
6.37
KB
-rw-r--r--
2026-04-20 11:09
test_getpath.py
44.36
KB
-rw-r--r--
2026-04-20 11:09
test_gettext.py
41.96
KB
-rw-r--r--
2026-04-20 11:09
test_glob.py
18.21
KB
-rw-r--r--
2026-04-20 11:09
test_global.py
1.2
KB
-rw-r--r--
2026-04-20 11:09
test_grammar.py
66.31
KB
-rw-r--r--
2026-04-20 11:09
test_graphlib.py
8.31
KB
-rw-r--r--
2026-04-20 11:09
test_grp.py
3.67
KB
-rw-r--r--
2026-04-20 11:09
test_gzip.py
41.48
KB
-rw-r--r--
2026-04-20 11:09
test_hash.py
12.11
KB
-rw-r--r--
2026-04-20 11:09
test_hashlib.py
46.71
KB
-rw-r--r--
2026-04-20 11:09
test_heapq.py
16.42
KB
-rw-r--r--
2026-04-20 11:09
test_hmac.py
26.06
KB
-rw-r--r--
2026-04-20 11:09
test_html.py
4.23
KB
-rw-r--r--
2026-04-20 11:09
test_htmlparser.py
45.58
KB
-rw-r--r--
2026-04-20 11:09
test_http_cookiejar.py
81.55
KB
-rw-r--r--
2026-04-20 11:09
test_http_cookies.py
23.59
KB
-rw-r--r--
2026-04-20 11:09
test_httplib.py
99.04
KB
-rw-r--r--
2026-04-20 11:09
test_httpservers.py
57.95
KB
-rw-r--r--
2026-04-20 11:09
test_idle.py
831
B
-rw-r--r--
2026-04-20 11:09
test_imaplib.py
42.11
KB
-rw-r--r--
2026-04-20 11:09
test_imghdr.py
4.81
KB
-rw-r--r--
2026-04-20 11:09
test_index.py
8.37
KB
-rw-r--r--
2026-04-20 11:09
test_int.py
33.97
KB
-rw-r--r--
2026-04-20 11:09
test_int_literal.py
6.89
KB
-rw-r--r--
2026-04-20 11:09
test_interpreters.py
32.11
KB
-rw-r--r--
2026-04-20 11:09
test_io.py
183.89
KB
-rw-r--r--
2026-04-20 11:09
test_ioctl.py
3.24
KB
-rw-r--r--
2026-04-20 11:09
test_ipaddress.py
126.69
KB
-rw-r--r--
2026-04-20 11:09
test_isinstance.py
12.95
KB
-rw-r--r--
2026-04-20 11:09
test_iter.py
38.23
KB
-rw-r--r--
2026-04-20 11:09
test_iterlen.py
7.1
KB
-rw-r--r--
2026-04-20 11:09
test_itertools.py
113.53
KB
-rw-r--r--
2026-04-20 11:09
test_keyword.py
2
KB
-rw-r--r--
2026-04-20 11:09
test_keywordonlyarg.py
6.89
KB
-rw-r--r--
2026-04-20 11:09
test_kqueue.py
9.36
KB
-rw-r--r--
2026-04-20 11:09
test_largefile.py
11.05
KB
-rw-r--r--
2026-04-20 11:09
test_launcher.py
28.75
KB
-rw-r--r--
2026-04-20 11:09
test_linecache.py
12.56
KB
-rw-r--r--
2026-04-20 11:09
test_list.py
9.6
KB
-rw-r--r--
2026-04-20 11:09
test_listcomps.py
24.02
KB
-rw-r--r--
2026-04-20 11:09
test_lltrace.py
3.71
KB
-rw-r--r--
2026-04-20 11:09
test_locale.py
24.69
KB
-rw-r--r--
2026-04-20 11:09
test_logging.py
251.7
KB
-rw-r--r--
2026-04-20 11:09
test_long.py
63.4
KB
-rw-r--r--
2026-04-20 11:09
test_longexp.py
233
B
-rw-r--r--
2026-04-20 11:09
test_lzma.py
93
KB
-rw-r--r--
2026-04-20 11:09
test_mailbox.py
93.91
KB
-rw-r--r--
2026-04-20 11:09
test_mailcap.py
11.48
KB
-rw-r--r--
2026-04-20 11:09
test_marshal.py
23.15
KB
-rw-r--r--
2026-04-20 11:09
test_math.py
108.3
KB
-rw-r--r--
2026-04-20 11:09
test_math_property.py
1.15
KB
-rw-r--r--
2026-04-20 11:09
test_memoryio.py
32.65
KB
-rw-r--r--
2026-04-20 11:09
test_memoryview.py
22.23
KB
-rw-r--r--
2026-04-20 11:09
test_metaclass.py
6.19
KB
-rw-r--r--
2026-04-20 11:09
test_mimetypes.py
15.74
KB
-rw-r--r--
2026-04-20 11:09
test_minidom.py
69.56
KB
-rw-r--r--
2026-04-20 11:09
test_mmap.py
38.56
KB
-rw-r--r--
2026-04-20 11:09
test_modulefinder.py
12.21
KB
-rw-r--r--
2026-04-20 11:09
test_monitoring.py
55.76
KB
-rw-r--r--
2026-04-20 11:09
test_msilib.py
5.52
KB
-rw-r--r--
2026-04-20 11:09
test_multibytecodec.py
15.79
KB
-rw-r--r--
2026-04-20 11:09
test_multiprocessing_main_handling.py
11.48
KB
-rw-r--r--
2026-04-20 11:09
test_named_expressions.py
29.62
KB
-rw-r--r--
2026-04-20 11:09
test_netrc.py
11.86
KB
-rw-r--r--
2026-04-20 11:09
test_nis.py
1.25
KB
-rw-r--r--
2026-04-20 11:09
test_nntplib.py
62.7
KB
-rw-r--r--
2026-04-20 11:09
test_ntpath.py
64.11
KB
-rw-r--r--
2026-04-20 11:09
test_numeric_tower.py
8
KB
-rw-r--r--
2026-04-20 11:09
test_opcache.py
10.89
KB
-rw-r--r--
2026-04-20 11:09
test_opcodes.py
3.62
KB
-rw-r--r--
2026-04-20 11:09
test_openpty.py
600
B
-rw-r--r--
2026-04-20 11:09
test_operator.py
26.72
KB
-rw-r--r--
2026-04-20 11:09
test_optparse.py
61.39
KB
-rw-r--r--
2026-04-20 11:09
test_ordered_dict.py
39.96
KB
-rw-r--r--
2026-04-20 11:09
test_os.py
181.05
KB
-rw-r--r--
2026-04-20 11:09
test_ossaudiodev.py
7.27
KB
-rw-r--r--
2026-04-20 11:09
test_osx_env.py
1.31
KB
-rw-r--r--
2026-04-20 11:09
test_pathlib.py
138.01
KB
-rw-r--r--
2026-04-20 11:09
test_patma.py
86.6
KB
-rw-r--r--
2026-04-20 11:09
test_pdb.py
92.92
KB
-rw-r--r--
2026-04-20 11:09
test_peepholer.py
40.6
KB
-rw-r--r--
2026-04-20 11:09
test_pep646_syntax.py
7.79
KB
-rw-r--r--
2026-04-20 11:09
test_perf_profiler.py
11.41
KB
-rw-r--r--
2026-04-20 11:09
test_perfmaps.py
685
B
-rw-r--r--
2026-04-20 11:09
test_pickle.py
21.24
KB
-rw-r--r--
2026-04-20 11:09
test_picklebuffer.py
4.99
KB
-rw-r--r--
2026-04-20 11:09
test_pickletools.py
16.78
KB
-rw-r--r--
2026-04-20 11:09
test_pipes.py
6.79
KB
-rw-r--r--
2026-04-20 11:09
test_pkg.py
9.59
KB
-rw-r--r--
2026-04-20 11:09
test_pkgutil.py
26.22
KB
-rw-r--r--
2026-04-20 11:09
test_platform.py
21.53
KB
-rw-r--r--
2026-04-20 11:09
test_plistlib.py
42.62
KB
-rw-r--r--
2026-04-20 11:09
test_poll.py
7.39
KB
-rw-r--r--
2026-04-20 11:09
test_popen.py
2.36
KB
-rw-r--r--
2026-04-20 11:09
test_poplib.py
18.02
KB
-rw-r--r--
2026-04-20 11:09
test_positional_only_arg.py
18.44
KB
-rw-r--r--
2026-04-20 11:09
test_posix.py
96.25
KB
-rw-r--r--
2026-04-20 11:09
test_posixpath.py
44.92
KB
-rw-r--r--
2026-04-20 11:09
test_pow.py
6.38
KB
-rw-r--r--
2026-04-20 11:09
test_pprint.py
50.59
KB
-rw-r--r--
2026-04-20 11:09
test_print.py
8.05
KB
-rw-r--r--
2026-04-20 11:09
test_profile.py
8.69
KB
-rw-r--r--
2026-04-20 11:09
test_property.py
19.33
KB
-rw-r--r--
2026-04-20 11:09
test_pstats.py
4.31
KB
-rw-r--r--
2026-04-20 11:09
test_pty.py
16.18
KB
-rw-r--r--
2026-04-20 11:09
test_pulldom.py
12.33
KB
-rw-r--r--
2026-04-20 11:09
test_pwd.py
4.32
KB
-rw-r--r--
2026-04-20 11:09
test_py_compile.py
11.93
KB
-rw-r--r--
2026-04-20 11:09
test_pyclbr.py
10.25
KB
-rw-r--r--
2026-04-20 11:09
test_pyexpat.py
39.22
KB
-rw-r--r--
2026-04-20 11:09
test_queue.py
20.61
KB
-rw-r--r--
2026-04-20 11:09
test_quopri.py
7.87
KB
-rw-r--r--
2026-04-20 11:09
test_raise.py
13.44
KB
-rw-r--r--
2026-04-20 11:09
test_random.py
57.01
KB
-rw-r--r--
2026-04-20 11:09
test_range.py
26.53
KB
-rw-r--r--
2026-04-20 11:09
test_re.py
144.79
KB
-rw-r--r--
2026-04-20 11:09
test_readline.py
15.72
KB
-rw-r--r--
2026-04-20 11:09
test_regrtest.py
92.51
KB
-rw-r--r--
2026-04-20 11:09
test_repl.py
6.34
KB
-rw-r--r--
2026-04-20 11:09
test_reprlib.py
29.07
KB
-rw-r--r--
2026-04-20 11:09
test_resource.py
7.12
KB
-rw-r--r--
2026-04-20 11:09
test_richcmp.py
11.95
KB
-rw-r--r--
2026-04-20 11:09
test_rlcompleter.py
7.4
KB
-rw-r--r--
2026-04-20 11:09
test_robotparser.py
11.02
KB
-rw-r--r--
2026-04-20 11:09
test_runpy.py
33.99
KB
-rw-r--r--
2026-04-20 11:09
test_sax.py
54.63
KB
-rw-r--r--
2026-04-20 11:09
test_sched.py
7.38
KB
-rw-r--r--
2026-04-20 11:09
test_scope.py
21.94
KB
-rw-r--r--
2026-04-20 11:09
test_script_helper.py
5.82
KB
-rw-r--r--
2026-04-20 11:09
test_secrets.py
4.28
KB
-rw-r--r--
2026-04-20 11:09
test_select.py
3.42
KB
-rw-r--r--
2026-04-20 11:09
test_selectors.py
19.64
KB
-rw-r--r--
2026-04-20 11:09
test_set.py
71.31
KB
-rw-r--r--
2026-04-20 11:09
test_setcomps.py
5.24
KB
-rw-r--r--
2026-04-20 11:09
test_shelve.py
6.42
KB
-rw-r--r--
2026-04-20 11:09
test_shlex.py
13.39
KB
-rw-r--r--
2026-04-20 11:09
test_shutil.py
136.86
KB
-rw-r--r--
2026-04-20 11:09
test_signal.py
52.58
KB
-rw-r--r--
2026-04-20 11:09
test_site.py
29.77
KB
-rw-r--r--
2026-04-20 11:09
test_slice.py
9.46
KB
-rw-r--r--
2026-04-20 11:09
test_smtplib.py
60.02
KB
-rw-r--r--
2026-04-20 11:09
test_smtpnet.py
3.03
KB
-rw-r--r--
2026-04-20 11:09
test_sndhdr.py
1.51
KB
-rw-r--r--
2026-04-20 11:09
test_socket.py
260.33
KB
-rw-r--r--
2026-04-20 11:09
test_socketserver.py
17.39
KB
-rw-r--r--
2026-04-20 11:09
test_sort.py
13.59
KB
-rw-r--r--
2026-04-20 11:09
test_source_encoding.py
12.65
KB
-rw-r--r--
2026-04-20 11:09
test_spwd.py
2.83
KB
-rw-r--r--
2026-04-20 11:09
test_ssl.py
216.52
KB
-rw-r--r--
2026-04-20 11:09
test_stable_abi_ctypes.py
24.75
KB
-rw-r--r--
2026-04-20 11:09
test_startfile.py
1.7
KB
-rw-r--r--
2026-04-20 11:09
test_stat.py
8.92
KB
-rw-r--r--
2026-04-20 11:09
test_statistics.py
120.02
KB
-rw-r--r--
2026-04-20 11:09
test_strftime.py
7.4
KB
-rw-r--r--
2026-04-20 11:09
test_string.py
21.86
KB
-rw-r--r--
2026-04-20 11:09
test_string_literals.py
14.1
KB
-rw-r--r--
2026-04-20 11:09
test_stringprep.py
3.04
KB
-rw-r--r--
2026-04-20 11:09
test_strptime.py
41.95
KB
-rw-r--r--
2026-04-20 11:09
test_strtod.py
20.06
KB
-rw-r--r--
2026-04-20 11:09
test_struct.py
39.18
KB
-rw-r--r--
2026-04-20 11:09
test_structseq.py
7.72
KB
-rw-r--r--
2026-04-20 11:09
test_subclassinit.py
8.04
KB
-rw-r--r--
2026-04-20 11:09
test_subprocess.py
161.37
KB
-rw-r--r--
2026-04-20 11:09
test_sunau.py
6.09
KB
-rw-r--r--
2026-04-20 11:09
test_sundry.py
1.02
KB
-rw-r--r--
2026-04-20 11:09
test_super.py
14.79
KB
-rw-r--r--
2026-04-20 11:09
test_support.py
27.05
KB
-rw-r--r--
2026-04-20 11:09
test_symtable.py
17.56
KB
-rw-r--r--
2026-04-20 11:09
test_syntax.py
73.95
KB
-rw-r--r--
2026-04-20 11:09
test_sys.py
67.37
KB
-rw-r--r--
2026-04-20 11:09
test_sys_setprofile.py
14.53
KB
-rw-r--r--
2026-04-20 11:09
test_sys_settrace.py
84.56
KB
-rw-r--r--
2026-04-20 11:09
test_sysconfig.py
26.08
KB
-rw-r--r--
2026-04-20 11:09
test_syslog.py
4.7
KB
-rw-r--r--
2026-04-20 11:09
test_tabnanny.py
13.9
KB
-rw-r--r--
2026-04-20 11:09
test_tarfile.py
180.51
KB
-rw-r--r--
2026-04-20 11:09
test_tcl.py
30.3
KB
-rw-r--r--
2026-04-20 11:09
test_telnetlib.py
12.85
KB
-rw-r--r--
2026-04-20 11:09
test_tempfile.py
75.5
KB
-rw-r--r--
2026-04-20 11:09
test_termios.py
10.96
KB
-rw-r--r--
2026-04-20 11:09
test_textwrap.py
41.89
KB
-rw-r--r--
2026-04-20 11:09
test_thread.py
8.87
KB
-rw-r--r--
2026-04-20 11:09
test_threadedtempfile.py
1.93
KB
-rw-r--r--
2026-04-20 11:09
test_threading.py
74.21
KB
-rw-r--r--
2026-04-20 11:09
test_threading_local.py
7.01
KB
-rw-r--r--
2026-04-20 11:09
test_threadsignals.py
9.87
KB
-rw-r--r--
2026-04-20 11:09
test_time.py
44.65
KB
-rw-r--r--
2026-04-20 11:09
test_timeit.py
15.2
KB
-rw-r--r--
2026-04-20 11:09
test_timeout.py
10.74
KB
-rw-r--r--
2026-04-20 11:09
test_tix.py
1.05
KB
-rw-r--r--
2026-04-20 11:09
test_tokenize.py
118
KB
-rw-r--r--
2026-04-20 11:09
test_trace.py
21.52
KB
-rw-r--r--
2026-04-20 11:09
test_traceback.py
144.4
KB
-rw-r--r--
2026-04-20 11:09
test_tracemalloc.py
40.97
KB
-rw-r--r--
2026-04-20 11:09
test_ttk_textonly.py
16.69
KB
-rw-r--r--
2026-04-20 11:09
test_tty.py
3.63
KB
-rw-r--r--
2026-04-20 11:09
test_tuple.py
19.8
KB
-rw-r--r--
2026-04-20 11:09
test_turtle.py
14.04
KB
-rw-r--r--
2026-04-20 11:09
test_type_aliases.py
12.74
KB
-rw-r--r--
2026-04-20 11:09
test_type_annotations.py
6.23
KB
-rw-r--r--
2026-04-20 11:09
test_type_cache.py
6.6
KB
-rw-r--r--
2026-04-20 11:09
test_type_comments.py
10.5
KB
-rw-r--r--
2026-04-20 11:09
test_type_params.py
38.87
KB
-rw-r--r--
2026-04-20 11:09
test_typechecks.py
2.55
KB
-rw-r--r--
2026-04-20 11:09
test_types.py
82.38
KB
-rw-r--r--
2026-04-20 11:09
test_typing.py
343.33
KB
-rw-r--r--
2026-04-20 11:09
test_ucn.py
9.71
KB
-rw-r--r--
2026-04-20 11:09
test_unary.py
1.52
KB
-rw-r--r--
2026-04-20 11:09
test_unicode.py
125.43
KB
-rw-r--r--
2026-04-20 11:09
test_unicode_file.py
5.72
KB
-rw-r--r--
2026-04-20 11:09
test_unicode_file_functions.py
6.91
KB
-rw-r--r--
2026-04-20 11:09
test_unicode_identifiers.py
997
B
-rw-r--r--
2026-04-20 11:09
test_unicodedata.py
17.01
KB
-rw-r--r--
2026-04-20 11:09
test_univnewlines.py
3.85
KB
-rw-r--r--
2026-04-20 11:09
test_unpack.py
3.51
KB
-rw-r--r--
2026-04-20 11:09
test_unpack_ex.py
9.98
KB
-rw-r--r--
2026-04-20 11:09
test_unparse.py
27.96
KB
-rw-r--r--
2026-04-20 11:09
test_urllib.py
73.04
KB
-rw-r--r--
2026-04-20 11:09
test_urllib2.py
80.82
KB
-rw-r--r--
2026-04-20 11:09
test_urllib2_localnet.py
25.64
KB
-rw-r--r--
2026-04-20 11:09
test_urllib2net.py
13.96
KB
-rw-r--r--
2026-04-20 11:09
test_urllib_response.py
2.04
KB
-rw-r--r--
2026-04-20 11:09
test_urllibnet.py
9.41
KB
-rw-r--r--
2026-04-20 11:09
test_urlparse.py
81.41
KB
-rw-r--r--
2026-04-20 11:09
test_userdict.py
7.56
KB
-rw-r--r--
2026-04-20 11:09
test_userlist.py
1.97
KB
-rw-r--r--
2026-04-20 11:09
test_userstring.py
2.52
KB
-rw-r--r--
2026-04-20 11:09
test_utf8_mode.py
10.31
KB
-rw-r--r--
2026-04-20 11:09
test_utf8source.py
1.08
KB
-rw-r--r--
2026-04-20 11:09
test_uu.py
9.2
KB
-rw-r--r--
2026-04-20 11:09
test_uuid.py
44.28
KB
-rw-r--r--
2026-04-20 11:09
test_venv.py
37.42
KB
-rw-r--r--
2026-04-20 11:09
test_wait3.py
1.74
KB
-rw-r--r--
2026-04-20 11:09
test_wait4.py
1.14
KB
-rw-r--r--
2026-04-20 11:09
test_wave.py
7.64
KB
-rw-r--r--
2026-04-20 11:09
test_weakref.py
74.32
KB
-rw-r--r--
2026-04-20 11:09
test_weakset.py
16.3
KB
-rw-r--r--
2026-04-20 11:09
test_webbrowser.py
10.5
KB
-rw-r--r--
2026-04-20 11:09
test_winapi.py
2.63
KB
-rw-r--r--
2026-04-20 11:09
test_winconsoleio.py
7.6
KB
-rw-r--r--
2026-04-20 11:09
test_winreg.py
22.48
KB
-rw-r--r--
2026-04-20 11:09
test_winsound.py
5.17
KB
-rw-r--r--
2026-04-20 11:09
test_with.py
27.78
KB
-rw-r--r--
2026-04-20 11:09
test_wmi.py
3.31
KB
-rw-r--r--
2026-04-20 11:09
test_wsgiref.py
30.25
KB
-rw-r--r--
2026-04-20 11:09
test_xdrlib.py
2.25
KB
-rw-r--r--
2026-04-20 11:09
test_xml_dom_minicompat.py
4.18
KB
-rw-r--r--
2026-04-20 11:09
test_xml_dom_xmlbuilder.py
3.1
KB
-rw-r--r--
2026-04-20 11:09
test_xml_etree.py
168.95
KB
-rw-r--r--
2026-04-20 11:09
test_xml_etree_c.py
9.34
KB
-rw-r--r--
2026-04-20 11:09
test_xmlrpc.py
58.08
KB
-rw-r--r--
2026-04-20 11:09
test_xmlrpc_net.py
954
B
-rw-r--r--
2026-04-20 11:09
test_xxlimited.py
2.46
KB
-rw-r--r--
2026-04-20 11:09
test_xxtestfuzz.py
690
B
-rw-r--r--
2026-04-20 11:09
test_yield_from.py
50.23
KB
-rw-r--r--
2026-04-20 11:09
test_zipapp.py
16.7
KB
-rw-r--r--
2026-04-20 11:09
test_zipfile64.py
5.78
KB
-rw-r--r--
2026-04-20 11:09
test_zipimport.py
31.88
KB
-rw-r--r--
2026-04-20 11:09
test_zipimport_support.py
10.57
KB
-rw-r--r--
2026-04-20 11:09
test_zlib.py
41.66
KB
-rw-r--r--
2026-04-20 11:09
testcodec.py
1.02
KB
-rw-r--r--
2026-04-20 11:09
testtar.tar
425
KB
-rw-r--r--
2026-03-03 16:09
testtar.tar.xz
172
B
-rw-r--r--
2026-03-03 16:09
tf_inherit_check.py
714
B
-rw-r--r--
2026-04-20 11:09
time_hashlib.py
2.87
KB
-rw-r--r--
2026-04-20 11:09
win_console_handler.py
1.38
KB
-rw-r--r--
2026-04-20 11:09
xmltests.py
499
B
-rw-r--r--
2026-04-20 11:09
zip_cp437_header.zip
270
B
-rw-r--r--
2026-03-03 16:09
zipdir.zip
374
B
-rw-r--r--
2026-03-03 16:09
zipdir_backslash.zip
192
B
-rw-r--r--
2026-03-03 16:09
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(): 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) self.assertTrue(inspect.isawaitable(g.aclose())) 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()) if __name__ == "__main__": unittest.main()