def consuming_from(self, queue):
        """Return :const:`True` if the consumer is currently
        consuming from queue'."""
        name = queue
        if isinstance(queue, Queue):
            name = queue.name
        return self._active_tags in name
dataset/ETHPy150Open celery/kombu/kombu/messaging.py/Consumer.consuming_from/swapped operands of `in`