loop = asyncio.get_event_loop()
engine = loop.run_until_complete(create_engine(config.DATABASE_URI, echo=config.DEBUG))
from db import engine
async def mycoro():
async with engine.acquire() as conn:
rows = await conn.execute('select 1')
for row in rows:
print(row)