bcb1f66e380a5ff9b1e93d731fcd02704dadceaa,utils/redis_raw_log_middleware.py,RedisDumpMiddleware,process_message,#RedisDumpMiddleware#,47

Before Change

        return instrumented_method
    
    def process_message(self, *args, **kwargs):
        query = " ".join([str(arg) for arg in args if not isinstance(arg, Connection)])
        return { "query": query, }

After Change

    
    def process_message(self, *args, **kwargs):
        query = []
        for a, arg in enumerate(args):
            if isinstance(arg, Connection):
                continue
            if args[1] == "RESTORE" and a == 4:
                arg = "[%s bytes]" % len(arg)
            query.append(str(arg).replace("\n", ""))
        return { "query": " ".join(query) }

Instances