def process(self, msg):
        if isinstance(msg, ChannelEventMessage):
            self.evm.ack_lock.acquire()
            self.evm.ack.append(msg)
            if MAX_ACK_QUEUE > len(self.evm.ack):
                self.evm.ack = self.evm.ack[-MAX_ACK_QUEUE:]
            self.evm.ack_lock.release()
dataset/ETHPy150Open mvillalba/python-ant/src/ant/core/event.py/AckCallback.process/swapped operands of `>`