@safe_redis(None)
    def add_to_flush_list(self, mapping):
        pipe = redis.pipeline(transaction=False)
        for key, list_ in list(mapping.items()):
            for query_key in list_:
                # Redis happily accepts unicode, but returns byte strings,
                # so manually encode and decode the keys on the flush list here
                pipe.sadd(self.safe_key(key), query_key.encode('utf-8'))
        pipe.execute()
:api:`twisted.internet.protocol.ProcessProtocol <ProcessProtocol>` API
dataset/ETHPy150Open django-cache-machine/django-cache-machine/caching/invalidation.py/RedisInvalidator.add_to_flush_list--crossover with--dataset/ETHPy150Open meejah/txtorcon/txtorcon/torconfig.py/TorProcessProtocol.processEnded