def METHOD_NAME(self, *args, **kwargs):
    # rewrap new connections.
    cloned = self.__wrapped__.METHOD_NAME(*args, **kwargs)
    traced_client = TracedClient(cloned)
    pin = ddtrace.Pin.get_from(self)
    if pin:
        pin.METHOD_NAME().onto(traced_client)
    return traced_client