File tree Expand file tree Collapse file tree
ext/opentelemetry-ext-aiohttp-client
src/opentelemetry/ext/aiohttp_client Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -175,9 +175,7 @@ async def on_request_start(
175175 trace .propagation .set_span_in_context (trace_config_ctx .span )
176176 )
177177
178- propagators .inject (
179- tracer , type (params .headers ).__setitem__ , params .headers
180- )
178+ propagators .inject (type (params .headers ).__setitem__ , params .headers )
181179
182180 async def on_request_end (
183181 unused_session : aiohttp .ClientSession ,
Original file line number Diff line number Diff line change @@ -71,7 +71,8 @@ def _http_request(
7171 """Helper to start an aiohttp test server and send an actual HTTP request to it."""
7272
7373 async def do_request ():
74- async def default_handler (unused_request ):
74+ async def default_handler (request ):
75+ assert "traceparent" in request .headers
7576 return aiohttp .web .Response (status = int (status_code ))
7677
7778 handler = request_handler or default_handler
@@ -281,8 +282,9 @@ async def do_request(url):
281282 self .memory_exporter .clear ()
282283
283284 def test_timeout (self ):
284- async def request_handler (unused_request ):
285+ async def request_handler (request ):
285286 await asyncio .sleep (1 )
287+ assert "traceparent" in request .headers
286288 return aiohttp .web .Response ()
287289
288290 host , port = self ._http_request (
@@ -312,6 +314,7 @@ def test_too_many_redirects(self):
312314 async def request_handler (request ):
313315 # Create a redirect loop.
314316 location = request .url
317+ assert "traceparent" in request .headers
315318 raise aiohttp .web .HTTPFound (location = location )
316319
317320 host , port = self ._http_request (
You can’t perform that action at this time.
0 commit comments