@@ -114,17 +114,17 @@ def foo():
114
114
p .wait (timeout = SHORT_TIMEOUT )
115
115
116
116
thread_expected_stack_trace = [
117
- ("foo" , script_name , 15 ),
118
- ("baz" , script_name , 12 ),
119
- ("bar" , script_name , 9 ),
120
- ('Thread.run' , threading .__file__ , ANY )
117
+ (script_name , 15 , "foo" ),
118
+ (script_name , 12 , "baz" ),
119
+ (script_name , 9 , "bar" ),
120
+ (threading .__file__ , ANY , 'Thread.run' )
121
121
]
122
122
# Is possible that there are more threads, so we check that the
123
123
# expected stack traces are in the result (looking at you Windows!)
124
124
self .assertIn ((ANY , thread_expected_stack_trace ), stack_trace )
125
125
126
126
# Check that the main thread stack trace is in the result
127
- frame = ("<module>" , script_name , 19 )
127
+ frame = (script_name , 19 , "<module>" )
128
128
for _ , stack in stack_trace :
129
129
if frame in stack :
130
130
break
@@ -222,70 +222,70 @@ def new_eager_loop():
222
222
root_task = "Task-1"
223
223
expected_stack_trace = [
224
224
[
225
- ("c5" , script_name , 10 ),
226
- ("c4" , script_name , 14 ),
227
- ("c3" , script_name , 17 ),
228
- ("c2" , script_name , 20 ),
225
+ (script_name , 10 , "c5" ),
226
+ (script_name , 14 , "c4" ),
227
+ (script_name , 17 , "c3" ),
228
+ (script_name , 20 , "c2" ),
229
229
],
230
230
"c2_root" ,
231
231
[
232
232
[
233
233
[
234
234
(
235
- "TaskGroup._aexit" ,
236
235
taskgroups .__file__ ,
237
236
ANY ,
237
+ "TaskGroup._aexit"
238
238
),
239
239
(
240
- "TaskGroup.__aexit__" ,
241
240
taskgroups .__file__ ,
242
241
ANY ,
242
+ "TaskGroup.__aexit__"
243
243
),
244
- ("main" , script_name , 26 ),
244
+ (script_name , 26 , "main" ),
245
245
],
246
246
"Task-1" ,
247
247
[],
248
248
],
249
249
[
250
- [("c1" , script_name , 23 )],
250
+ [(script_name , 23 , "c1" )],
251
251
"sub_main_1" ,
252
252
[
253
253
[
254
254
[
255
255
(
256
- "TaskGroup._aexit" ,
257
256
taskgroups .__file__ ,
258
257
ANY ,
258
+ "TaskGroup._aexit"
259
259
),
260
260
(
261
- "TaskGroup.__aexit__" ,
262
261
taskgroups .__file__ ,
263
262
ANY ,
263
+ "TaskGroup.__aexit__"
264
264
),
265
- ("main" , script_name , 26 ),
265
+ (script_name , 26 , "main" ),
266
266
],
267
267
"Task-1" ,
268
268
[],
269
269
]
270
270
],
271
271
],
272
272
[
273
- [("c1" , script_name , 23 )],
273
+ [(script_name , 23 , "c1" )],
274
274
"sub_main_2" ,
275
275
[
276
276
[
277
277
[
278
278
(
279
- "TaskGroup._aexit" ,
280
279
taskgroups .__file__ ,
281
280
ANY ,
281
+ "TaskGroup._aexit"
282
282
),
283
283
(
284
- "TaskGroup.__aexit__" ,
285
284
taskgroups .__file__ ,
286
285
ANY ,
286
+ "TaskGroup.__aexit__"
287
287
),
288
- ("main" , script_name , 26 ),
288
+ (script_name , 26 , "main" ),
289
289
],
290
290
"Task-1" ,
291
291
[],
@@ -363,9 +363,9 @@ async def main():
363
363
364
364
expected_stack_trace = [
365
365
[
366
- ("gen_nested_call" , script_name , 10 ),
367
- ("gen" , script_name , 16 ),
368
- ("main" , script_name , 19 ),
366
+ (script_name , 10 , "gen_nested_call" ),
367
+ (script_name , 16 , "gen" ),
368
+ (script_name , 19 , "main" ),
369
369
],
370
370
"Task-1" ,
371
371
[],
@@ -439,9 +439,9 @@ async def main():
439
439
stack_trace [2 ].sort (key = lambda x : x [1 ])
440
440
441
441
expected_stack_trace = [
442
- [("deep" , script_name , 11 ), ( "c1" , script_name , 15 )],
442
+ [(script_name , 11 , "deep" ), ( script_name , 15 , "c1" )],
443
443
"Task-2" ,
444
- [[[("main" , script_name , 21 )], "Task-1" , []]],
444
+ [[[(script_name , 21 , "main" )], "Task-1" , []]],
445
445
]
446
446
self .assertEqual (stack_trace , expected_stack_trace )
447
447
@@ -515,16 +515,16 @@ async def main():
515
515
stack_trace [2 ].sort (key = lambda x : x [1 ])
516
516
expected_stack_trace = [
517
517
[
518
- ("deep" , script_name , 11 ),
519
- ("c1" , script_name , 15 ),
520
- ("staggered_race.<locals>.run_one_coro" , staggered . __file__ , ANY ),
518
+ (script_name , 11 , "deep" ),
519
+ (script_name , 15 , "c1" ),
520
+ (staggered . __file__ , ANY , "staggered_race.<locals>.run_one_coro" ),
521
521
],
522
522
"Task-2" ,
523
523
[
524
524
[
525
525
[
526
- ("staggered_race" , staggered .__file__ , ANY ),
527
- ("main" , script_name , 21 ),
526
+ (staggered .__file__ , ANY , "staggered_race" ),
527
+ (script_name , 21 , "main" ),
528
528
],
529
529
"Task-1" ,
530
530
[],
@@ -662,16 +662,16 @@ async def main():
662
662
self .assertIn ((ANY , "Task-1" , []), entries )
663
663
main_stack = [
664
664
(
665
- "TaskGroup._aexit" ,
666
665
taskgroups .__file__ ,
667
666
ANY ,
667
+ "TaskGroup._aexit" ,
668
668
),
669
669
(
670
- "TaskGroup.__aexit__" ,
671
670
taskgroups .__file__ ,
672
671
ANY ,
672
+ "TaskGroup.__aexit__" ,
673
673
),
674
- ("main" , script_name , 60 ),
674
+ (script_name , 60 , "main" ),
675
675
]
676
676
self .assertIn (
677
677
(ANY , "server task" , [[main_stack , ANY ]]),
@@ -686,16 +686,16 @@ async def main():
686
686
[
687
687
[
688
688
(
689
- "TaskGroup._aexit" ,
690
689
taskgroups .__file__ ,
691
690
ANY ,
691
+ "TaskGroup._aexit" ,
692
692
),
693
693
(
694
- "TaskGroup.__aexit__" ,
695
694
taskgroups .__file__ ,
696
695
ANY ,
696
+ "TaskGroup.__aexit__" ,
697
697
),
698
- ("echo_client_spam" , script_name , 41 ),
698
+ (script_name , 41 , "echo_client_spam" ),
699
699
],
700
700
ANY ,
701
701
]
@@ -741,14 +741,14 @@ def test_self_trace(self):
741
741
stack [:2 ],
742
742
[
743
743
(
744
- "get_stack_trace" ,
745
744
__file__ ,
746
745
get_stack_trace .__code__ .co_firstlineno + 2 ,
746
+ "get_stack_trace" ,
747
747
),
748
748
(
749
- "TestGetStackTrace.test_self_trace" ,
750
749
__file__ ,
751
750
self .test_self_trace .__code__ .co_firstlineno + 6 ,
751
+ "TestGetStackTrace.test_self_trace" ,
752
752
),
753
753
]
754
754
)
0 commit comments