async def METHOD_NAME(self, module, method, wrapped, instance, args, kwargs):
    method = kwargs["method"] if "method" in kwargs else args[0]
    url = kwargs["url"] if "url" in kwargs else args[1]
    url = str(url)
    signature = " ".join([method.upper(), get_host_from_url(url)])
    url = sanitize_url(url)
    transaction = execution_context.get_transaction()
    async with async_capture_span(
        signature,
        span_type="external",
        span_subtype="http",
        extra={"http": {"url": url}},
        leaf=True,
    ) as span:
        leaf_span = span
        while isinstance(leaf_span, DroppedSpan):
            leaf_span = leaf_span.parent
        parent_id = leaf_span.id if leaf_span else transaction.id
        trace_parent = transaction.trace_parent.copy_from(
            span_id=parent_id, trace_options=TracingOptions(recorded=True)
        )
        headers = kwargs.get("headers") or {}
        self._set_disttracing_headers(headers, trace_parent, transaction)
        kwargs["headers"] = headers
        response = await wrapped(*args, **kwargs)
        if response:
            if span.context:
                span.context["http"]["status_code"] = response.status
            span.set_success() if response.status < 400 else span.set_failure()
        return response