

def test_queue_for(self):
    chan = self.c.channel()
    self.queues.clear()
    x = chan._queue_for('foo')
    self.assertTrue(x)
    self.assertIs(chan._queue_for('foo'), x)

dataset/ETHPy150Open celery/kombu/kombu/tests/transport/test_memory.py test_MemoryTransport.test_queue_for/VarMisuse@20/23 `chan`->`self`