def remove_node(self, addr):
        if self.addrs not in addr: return
        
        self.init()
        
        self.distributor.remove_node(addr)
        self.addrs.remove(addr)
                
        self.mq_node.batch_put(self.caches[addr])
        del self.caches[addr]
        del self.caches_inited[addr]
        del self.backup_caches[addr]
        for o_addr in self.addrs:
            if o_addr != addr:
                del self.backup_caches[o_addr][addr]
         
        self.flush()
        
        BATCH_SIZE = 10
        objs = self.mq_node.get_backup(addr, size=BATCH_SIZE)
        while len(objs) > 0:
            self.mq_node.batch_put(objs)
            objs = self.mq_node.get_backup(addr, size=BATCH_SIZE)
        
        self.mq_node.remove_node(addr)
dataset/ETHPy150Open chineking/cola/cola/core/mq/node.py/MessageQueueNodeProxy.remove_node/swapped operands of `not in`