def _process_waiters(self):
        new_waiters = []
        firing_waiters = []
        while self.waiters:
            d, total_messages = self.waiters.pop(0)
            if total_messages >= len(self.received_messages):
                firing_waiters.append(d)
            else:
                new_waiters.append((d, total_messages))
        self.waiters = new_waiters
        for d in firing_waiters:
            d.callback(self.received_messages[:])
dataset/ETHPy150Open calston/tensor/tensor/tests/test_service.py/FakeRiemannServerFactory._process_waiters/swapped operands of `>=`