Example database file

database.py

import asyncpg
import asyncio

DATABASE_POOL = None


async def get_connection_pool():
    if DATABASE_POOL is None:
        await asyncio.sleep(1)
        return await get_connection_pool()
    return DATABASE_POOL


async def connect():
    global DATABASE_POOL
    DATABASE_POOL = await asyncpg.create_pool(
        user='guest',
        password='guest',
        database='ninja',
        host='127.0.0.1')
    print('DB Connection pool created')
    return DATABASE_POOL


if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(connect())