@property
    def active_queues(self):
        """Set of queues being consumed from (excluding fanout queues)."""
        return {queue for queue in self._active_queues
                if self.active_fanout_queues not in queue}
dataset/ETHPy150Open celery/kombu/kombu/transport/redis.py/Channel.active_queues/swapped operands of `not in`