import txaio txaio.use_asyncio() f0 = txaio.create_future()