Не срабатывают триггеры в sqlalchemy.orm

from databases import Database
from sqlalchemy import DDL, event
 
from . import db
 
database = Database(db.url_db.render_as_string())
db.Base.metadata.create_all(db.engine)
 
unique_info_values = DDL(
    """
    CREATE OR REPLACE FUNCTION unique_values() RETURNS TRIGGER AS $$ 
    BEGIN
        IF (SELECT COUNT(*) FROM Info WHERE (Info.A, Info.B) = (NEW.B, NEW.A)) > 0 THEN 
            RAISE '23Q01' USING message=format('Such Info %s are exist', NEW); 
    END IF; 
    END; $$ LANGUAGE PLPGSQL
    """,
    bind=db.engine
)
 
triger_unique_info_values = DDL(
    """
    CREATE OR REPLACE TRIGGER unique_info_values BEFORE INSERT OR UPDATE ON Info 
    FOR EACH STATEMENT EXECUTE PROCEDURE unique_values();
    """,
    bind=db.engine
)
 
event.listen(db.Info, "before_insert", unique_info_values.execute_if(dialect=("postgresql", "sqlalchemy")))
event.listen(db.Info, "before_update", unique_info_values.execute_if(dialect=("postgresql", "sqlalchemy")))
event.listen(db.Info, "before_insert", triger_unique_info_values.execute_if(dialect=("postgresql", "sqlalchemy")))
event.listen(db.Info, "before_update", triger_unique_info_values.execute_if(dialect=("postgresql", "sqlalchemy")))

from databases import Database
from sqlalchemy import DDL, event
 
from . import db
 
database = Database(db.url_db.render_as_string())
db.Base.metadata.create_all(db.engine)
 
 
#Подказали , что "after_create" прослушивается только у ядра sql alchemy, то ест ь после создания таблицы, будет создана эта процедура:
@event.listens_for(db.Info.__table__, "after_create")
def replace_after_create(target, connection, **kwargs):
    connection.execute(
        """
        CREATE OR REPLACE FUNCTION check_unique_info() RETURNS TRIGGER AS $$ 
        BEGIN
        IF (SELECT COUNT(*) FROM Friends WHERE (Info.A, Info.B) = (NEW.B, NEW.A)) > 0 THEN 
            RAISE EXCEPTION 'Such Info % are exist', NEW; 
        END IF; 
        RETURN NEW;
        END; $$ LANGUAGE PLPGSQL
        """
    )
 
 
triger_unique_info_values = DDL(
    """
    CREATE TRIGGER unique_info BEFORE INSERT OR BEFORE UPDATE ON Info
    FOR EACH ROW EXECUTE FUNCTION check_unique_info();
    """,
    bind=db.engine
)
 
 
event.listen(db.Info, "before_insert", triger_unique_info_values.execute_if(dialect=("postgresql", "sqlalchemy")))
event.listen(db.Info, "before_update", triger_unique_info_values.execute_if(dialect=("postgresql", "sqlalchemy")))