async def METHOD_NAME(app: web.Application, product_data: dict[str, Any]) -> RowProxy:
    """Injects product_data in products table and returns the associated table's database row
    Note that product_data is a SUBSET of product_row (e.g. modified dattimes etc)!
    """
    engine = app[APP_DB_ENGINE_KEY]
    assert engine
    async with engine.acquire() as conn:
        # writes
        insert_stmt = (
            products.insert().values(**product_data).returning(products.c.name)
        )
        name = await conn.scalar(insert_stmt)
        # reads
        select_stmt = sa.select(products).where(products.c.name == name)
        row = await (await conn.execute(select_stmt)).fetchone()
        assert row
        return row