def METHOD_NAME(func, instance, args, kwargs):
    pin = Pin.get_from(instance)
    if not pin or not pin.enabled():
        return func(*args, **kwargs)
    if is_cluster:
        cmds = [
            stringify_cache_args(c.args, cmd_max_len=integration_config.cmd_max_length)
            for c in instance.command_stack
        ]
    else:
        cmds = [
            stringify_cache_args(c, cmd_max_len=integration_config.cmd_max_length)
            for c, _ in instance.command_stack
        ]
    resource = "\n".join(cmds)
    with _trace_redis_execute_pipeline(pin, integration_config, resource, instance, is_cluster):
        return func(*args, **kwargs)