async def METHOD_NAME():
    async with pg_engine.acquire() as conn:
        async for product_row in await conn.execute(
            sa.select(products.c.name, products.c.group_id).order_by(
                products.c.priority
            )
        ):
            # get or create
            product_group_id = await get_or_create_product_group(
                conn, product_name=product_row.name
            )
            return product_group_id