26
26
27
27
from .test_asgi_middleware import simple_asgi
28
28
29
- _TIMEOUT = 0.01
30
-
31
29
32
30
async def http_app_with_custom_headers (scope , receive , send ):
33
31
message = await receive ()
@@ -136,7 +134,7 @@ async def test_http_custom_request_headers_in_span_attributes(self):
136
134
)
137
135
self .seed_app (self .app )
138
136
await self .send_default_request ()
139
- await self .get_all_output (_TIMEOUT )
137
+ await self .get_all_output ()
140
138
span_list = self .exporter .get_finished_spans ()
141
139
expected = {
142
140
"http.request.header.custom_test_header_1" : (
@@ -164,7 +162,7 @@ async def test_http_repeat_request_headers_in_span_attributes(self):
164
162
)
165
163
self .seed_app (self .app )
166
164
await self .send_default_request ()
167
- await self .get_all_output (_TIMEOUT )
165
+ await self .get_all_output ()
168
166
span_list = self .exporter .get_finished_spans ()
169
167
expected = {
170
168
"http.request.header.custom_test_header_1" : (
@@ -183,7 +181,7 @@ async def test_http_custom_request_headers_not_in_span_attributes(self):
183
181
)
184
182
self .seed_app (self .app )
185
183
await self .send_default_request ()
186
- await self .get_all_output (_TIMEOUT )
184
+ await self .get_all_output ()
187
185
span_list = self .exporter .get_finished_spans ()
188
186
expected = {
189
187
"http.request.header.custom_test_header_1" : (
@@ -209,7 +207,7 @@ async def test_http_custom_response_headers_in_span_attributes(self):
209
207
)
210
208
self .seed_app (self .app )
211
209
await self .send_default_request ()
212
- await self .get_all_output (_TIMEOUT )
210
+ await self .get_all_output ()
213
211
span_list = self .exporter .get_finished_spans ()
214
212
expected = {
215
213
"http.response.header.custom_test_header_1" : (
@@ -238,7 +236,7 @@ async def test_http_repeat_response_headers_in_span_attributes(self):
238
236
)
239
237
self .seed_app (self .app )
240
238
await self .send_default_request ()
241
- await self .get_all_output (_TIMEOUT )
239
+ await self .get_all_output ()
242
240
span_list = self .exporter .get_finished_spans ()
243
241
expected = {
244
242
"http.response.header.custom_test_header_1" : (
@@ -257,7 +255,7 @@ async def test_http_custom_response_headers_not_in_span_attributes(self):
257
255
)
258
256
self .seed_app (self .app )
259
257
await self .send_default_request ()
260
- await self .get_all_output (_TIMEOUT )
258
+ await self .get_all_output ()
261
259
span_list = self .exporter .get_finished_spans ()
262
260
not_expected = {
263
261
"http.response.header.custom_test_header_3" : (
@@ -291,7 +289,7 @@ async def test_websocket_custom_request_headers_in_span_attributes(self):
291
289
await self .send_input ({"type" : "websocket.receive" , "text" : "ping" })
292
290
await self .send_input ({"type" : "websocket.disconnect" })
293
291
294
- await self .get_all_output (_TIMEOUT )
292
+ await self .get_all_output ()
295
293
span_list = self .exporter .get_finished_spans ()
296
294
expected = {
297
295
"http.request.header.custom_test_header_1" : (
@@ -331,7 +329,7 @@ async def test_websocket_custom_request_headers_not_in_span_attributes(
331
329
await self .send_input ({"type" : "websocket.receive" , "text" : "ping" })
332
330
await self .send_input ({"type" : "websocket.disconnect" })
333
331
334
- await self .get_all_output (_TIMEOUT )
332
+ await self .get_all_output ()
335
333
span_list = self .exporter .get_finished_spans ()
336
334
not_expected = {
337
335
"http.request.header.custom_test_header_3" : (
@@ -363,7 +361,7 @@ async def test_websocket_custom_response_headers_in_span_attributes(self):
363
361
await self .send_input ({"type" : "websocket.connect" })
364
362
await self .send_input ({"type" : "websocket.receive" , "text" : "ping" })
365
363
await self .send_input ({"type" : "websocket.disconnect" })
366
- await self .get_all_output (_TIMEOUT )
364
+ await self .get_all_output ()
367
365
span_list = self .exporter .get_finished_spans ()
368
366
expected = {
369
367
"http.response.header.custom_test_header_1" : (
@@ -406,7 +404,7 @@ async def test_websocket_custom_response_headers_not_in_span_attributes(
406
404
await self .send_input ({"type" : "websocket.connect" })
407
405
await self .send_input ({"type" : "websocket.receive" , "text" : "ping" })
408
406
await self .send_input ({"type" : "websocket.disconnect" })
409
- await self .get_all_output (_TIMEOUT )
407
+ await self .get_all_output ()
410
408
span_list = self .exporter .get_finished_spans ()
411
409
not_expected = {
412
410
"http.response.header.custom_test_header_3" : (
0 commit comments