foo()
def foo():
- sock.sendall(b"ready"); time.sleep(1000) # same line number
+ sock.sendall(b"ready"); time.sleep(10_000) # same line number
bar()
"""
sock.connect(('localhost', {port}))
def c5():
- sock.sendall(b"ready")
- time.sleep(10000)
+ sock.sendall(b"ready"); time.sleep(10_000) # same line number
async def c4():
await asyncio.sleep(0)
root_task = "Task-1"
expected_stack_trace = [
[
- ("c5", script_name, 11),
- ("c4", script_name, 15),
- ("c3", script_name, 18),
- ("c2", script_name, 21),
+ ("c5", script_name, 10),
+ ("c4", script_name, 14),
+ ("c3", script_name, 17),
+ ("c2", script_name, 20),
],
"c2_root",
[
taskgroups.__file__,
ANY,
),
- ("main", script_name, 27),
+ ("main", script_name, 26),
],
"Task-1",
[],
],
[
- [("c1", script_name, 24)],
+ [("c1", script_name, 23)],
"sub_main_1",
[
[
taskgroups.__file__,
ANY,
),
- ("main", script_name, 27),
+ ("main", script_name, 26),
],
"Task-1",
[],
],
],
[
- [("c1", script_name, 24)],
+ [("c1", script_name, 23)],
"sub_main_2",
[
[
taskgroups.__file__,
ANY,
),
- ("main", script_name, 27),
+ ("main", script_name, 26),
],
"Task-1",
[],
sock.connect(('localhost', {port}))
async def gen_nested_call():
- sock.sendall(b"ready")
- time.sleep(10000)
+ sock.sendall(b"ready"); time.sleep(10_000) # same line number
async def gen():
for num in range(2):
expected_stack_trace = [
[
- ("gen_nested_call", script_name, 11),
- ("gen", script_name, 17),
- ("main", script_name, 20),
+ ("gen_nested_call", script_name, 10),
+ ("gen", script_name, 16),
+ ("main", script_name, 19),
],
"Task-1",
[],
async def deep():
await asyncio.sleep(0)
- sock.sendall(b"ready")
- time.sleep(10000)
+ sock.sendall(b"ready"); time.sleep(10_000) # same line number
async def c1():
await asyncio.sleep(0)
stack_trace[2].sort(key=lambda x: x[1])
expected_stack_trace = [
- [("deep", script_name, ANY), ("c1", script_name, 16)],
+ [("deep", script_name, 11), ("c1", script_name, 15)],
"Task-2",
- [[[("main", script_name, 22)], "Task-1", []]],
+ [[[("main", script_name, 21)], "Task-1", []]],
]
self.assertEqual(stack_trace, expected_stack_trace)
async def deep():
await asyncio.sleep(0)
- sock.sendall(b"ready")
- time.sleep(10000)
+ sock.sendall(b"ready"); time.sleep(10_000) # same line number
async def c1():
await asyncio.sleep(0)
await deep()
async def c2():
- await asyncio.sleep(10000)
+ await asyncio.sleep(10_000)
async def main():
await asyncio.staggered.staggered_race(
stack_trace[2].sort(key=lambda x: x[1])
expected_stack_trace = [
[
- ("deep", script_name, ANY),
- ("c1", script_name, 16),
+ ("deep", script_name, 11),
+ ("c1", script_name, 15),
("staggered_race.<locals>.run_one_coro", staggered.__file__, ANY),
],
"Task-2",
[
[
("staggered_race", staggered.__file__, ANY),
- ("main", script_name, 22),
+ ("main", script_name, 21),
],
"Task-1",
[],