async def METHOD_NAME(self):
    queue = TaskQueue()
    task = queue.run(retval(1, delay=5))
    await queue.complete(0.01)
    # cancellation may take a second
    # assert task.cancelled()
    with self.assertRaises(asyncio.CancelledError):
        await task