remove _TIMEOUT

Signed-off-by: emdneto <[email protected]>
open-telemetry · Aug 24, 2024 · bddb238 · bddb238
1 parent 91cbfd3
commit bddb238
Show file tree

Hide file tree

Showing 2 changed files with 49 additions and 52 deletions.
diff --git a/instrumentation/opentelemetry-instrumentation-asgi/tests/test_asgi_custom_headers.py b/instrumentation/opentelemetry-instrumentation-asgi/tests/test_asgi_custom_headers.py
@@ -26,8 +26,6 @@
 
 from .test_asgi_middleware import simple_asgi
 
-_TIMEOUT = 0.01
-
 
 async def http_app_with_custom_headers(scope, receive, send):
     message = await receive()
@@ -136,7 +134,7 @@ async def test_http_custom_request_headers_in_span_attributes(self):
         )
         self.seed_app(self.app)
         await self.send_default_request()
-        await self.get_all_output(_TIMEOUT)
+        await self.get_all_output()
         span_list = self.exporter.get_finished_spans()
         expected = {
             "http.request.header.custom_test_header_1": (
@@ -164,7 +162,7 @@ async def test_http_repeat_request_headers_in_span_attributes(self):
         )
         self.seed_app(self.app)
         await self.send_default_request()
-        await self.get_all_output(_TIMEOUT)
+        await self.get_all_output()
         span_list = self.exporter.get_finished_spans()
         expected = {
             "http.request.header.custom_test_header_1": (
@@ -183,7 +181,7 @@ async def test_http_custom_request_headers_not_in_span_attributes(self):
         )
         self.seed_app(self.app)
         await self.send_default_request()
-        await self.get_all_output(_TIMEOUT)
+        await self.get_all_output()
         span_list = self.exporter.get_finished_spans()
         expected = {
             "http.request.header.custom_test_header_1": (
@@ -209,7 +207,7 @@ async def test_http_custom_response_headers_in_span_attributes(self):
         )
         self.seed_app(self.app)
         await self.send_default_request()
-        await self.get_all_output(_TIMEOUT)
+        await self.get_all_output()
         span_list = self.exporter.get_finished_spans()
         expected = {
             "http.response.header.custom_test_header_1": (
@@ -238,7 +236,7 @@ async def test_http_repeat_response_headers_in_span_attributes(self):
         )
         self.seed_app(self.app)
         await self.send_default_request()
-        await self.get_all_output(_TIMEOUT)
+        await self.get_all_output()
         span_list = self.exporter.get_finished_spans()
         expected = {
             "http.response.header.custom_test_header_1": (
@@ -257,7 +255,7 @@ async def test_http_custom_response_headers_not_in_span_attributes(self):
         )
         self.seed_app(self.app)
         await self.send_default_request()
-        await self.get_all_output(_TIMEOUT)
+        await self.get_all_output()
         span_list = self.exporter.get_finished_spans()
         not_expected = {
             "http.response.header.custom_test_header_3": (
@@ -291,7 +289,7 @@ async def test_websocket_custom_request_headers_in_span_attributes(self):
         await self.send_input({"type": "websocket.receive", "text": "ping"})
         await self.send_input({"type": "websocket.disconnect"})
 
-        await self.get_all_output(_TIMEOUT)
+        await self.get_all_output()
         span_list = self.exporter.get_finished_spans()
         expected = {
             "http.request.header.custom_test_header_1": (
@@ -331,7 +329,7 @@ async def test_websocket_custom_request_headers_not_in_span_attributes(
         await self.send_input({"type": "websocket.receive", "text": "ping"})
         await self.send_input({"type": "websocket.disconnect"})
 
-        await self.get_all_output(_TIMEOUT)
+        await self.get_all_output()
         span_list = self.exporter.get_finished_spans()
         not_expected = {
             "http.request.header.custom_test_header_3": (
@@ -363,7 +361,7 @@ async def test_websocket_custom_response_headers_in_span_attributes(self):
         await self.send_input({"type": "websocket.connect"})
         await self.send_input({"type": "websocket.receive", "text": "ping"})
         await self.send_input({"type": "websocket.disconnect"})
-        await self.get_all_output(_TIMEOUT)
+        await self.get_all_output()
         span_list = self.exporter.get_finished_spans()
         expected = {
             "http.response.header.custom_test_header_1": (
@@ -406,7 +404,7 @@ async def test_websocket_custom_response_headers_not_in_span_attributes(
         await self.send_input({"type": "websocket.connect"})
         await self.send_input({"type": "websocket.receive", "text": "ping"})
         await self.send_input({"type": "websocket.disconnect"})
-        await self.get_all_output(_TIMEOUT)
+        await self.get_all_output()
         span_list = self.exporter.get_finished_spans()
         not_expected = {
             "http.response.header.custom_test_header_3": (