async def METHOD_NAME(
    app: web.Application, user_id: UserID, product_name: str
) -> GroupID:
    async with get_database_engine(app).acquire() as conn:
        return await _db.METHOD_NAME(
            conn, user_id=user_id, product_name=product_name
        )