def _flush(self):
        """Flush dirty (acked/rejected) tags from."""
        dirty = self._dirty
        delivered = self._delivered
        while 1:
            try:
                dirty_tag = dirty.pop()
            except __HOLE__:
                break
            delivered.pop(dirty_tag, None)
dataset/ETHPy150Open celery/kombu/kombu/transport/virtual/__init__.py/QoS._flush