def METHOD_NAME(engine_with_schema):
    engine, _ = engine_with_schema
    sel = select(
        sa_call_sql_function(
            email.EMAIL_LOCAL_PART,
            text("'test@example.com'"),
            return_type=PostgresType.TEXT
        )
    )
    with engine.begin() as conn:
        res = conn.execute(sel)
        assert res.fetchone()[0] == "test"