

@gen_test
def test_put_timeout_preempted(self):
    q = queues.Queue(1)
    q.put_nowait(0)
    put = q.put(1, timeout=timedelta(seconds=0.01))
    put.get()
    (yield gen.sleep(0.02))
    (yield put)

dataset/ETHPy150Open tornadoweb/tornado/tornado/test/queues_test.py QueuePutTest.test_put_timeout_preempted/VarMisuse@47/56 `q`->`put`