Fix aio-pika instrumentation bug causing the consumer callback to not be included in the trace

Signed-off-by: Tobias Michels <[email protected]>

Author: tobmi1

src/instana/instrumentation/aio_pika.py

@@ -100,12 +100,12 @@ async def callback_wrapper(
                 _extract_span_attributes(
                     span, connection, "consume", message.routing_key, message.exchange
                 )
-            try:
-                response = await wrapped(*args, **kwargs)
-            except Exception as exc:
-                span.record_exception(exc)
-            else:
-                return response
+                try:
+                    response = await wrapped(*args, **kwargs)
+                except Exception as exc:
+                    span.record_exception(exc)
+                else:
+                    return response
 
         wrapped_callback = callback_wrapper(callback)
         if kwargs.get("callback"):