

def test_check_ready(self):
    self.store.get('1234').AndReturn((self.env, 0))
    self.relay._attempt(self.env, 0)
    queue.store.remove('1234')
    self.mox.ReplayAll()
    queue = Queue(self.store, self.relay, store_pool=Pool(5))
    queue._add_queued((10, '1234'))
    queue._check_ready(20)
    queue.store_pool.join()

dataset/ETHPy150Open slimta/python-slimta/test/test_slimta_queue.py TestQueue.test_check_ready/VarMisuse@43/50 `self`->`queue`