def _Dequeue(self):
    """Attempt to get a sink from the cache.

    Returns:
      A sink if one can be taken from the cache, else None.
    """
    while any(self._cache):
      item = self._cache.popleft()
      if ChannelState.Open <= item.state:
        return item
      else:
        self._DiscardSink(item)
    return None
dataset/ETHPy150Open steveniemitz/scales/scales/pool/watermark.py/WatermarkPoolSink._Dequeue/swapped operands of `<=`