async def METHOD_NAME():
    users = [
        # username, login_id, is_developer, is_service_account
        ('auth', None, 0, 1),
        ('ci', None, 0, 1),
        ('test', None, 0, 0),
        ('test-dev', None, 1, 0),
        ('grafana', None, 0, 1),
    ]
    app = {}
    db = Database()
    await db.async_init(maxsize=50)
    app['db'] = db
    db_instance = Database()
    await db_instance.async_init(maxsize=50, config_file='/database-server-config/sql-config.json')
    app['db_instance'] = db_instance
    # kube.config.load_incluster_config()
    await kubernetes_asyncio.config.load_kube_config()
    k8s_client = kubernetes_asyncio.client.CoreV1Api()
    try:
        app['k8s_client'] = k8s_client
        app['identity_client'] = get_identity_client(credentials_file='/auth-gsa-key/key.json')
        for username, login_id, is_developer, is_service_account in users:
            user_id = await insert_user_if_not_exists(app, username, login_id, is_developer, is_service_account)
            if user_id is not None:
                db_user = await db.execute_and_fetchone('SELECT * FROM users where id = %s;', (user_id,))
                await create_user(app, db_user, skip_trial_bp=True)
    finally:
        await k8s_client.api_client.rest_client.pool_manager.close()