diff --git a/airflow/models/trigger.py b/airflow/models/trigger.py
index c3d6919645ab7..225e729489fe9 100644
--- a/airflow/models/trigger.py
+++ b/airflow/models/trigger.py
@@ -169,14 +169,16 @@ def clean_unused(cls, session: Session = NEW_SESSION) -> None:
                     .values(trigger_id=None)
                 )
 
-        # Get all triggers that have no task instances depending on them...
-        ids = session.scalars(
+        # Get all triggers that have no task instances depending on them and delete them
+        ids = (
             select(cls.id)
             .join(TaskInstance, cls.id == TaskInstance.trigger_id, isouter=True)
             .group_by(cls.id)
             .having(func.count(TaskInstance.trigger_id) == 0)
-        ).all()
-        # ...and delete them (we can't do this in one query due to MySQL)
+        )
+        if session.bind.dialect.name == "mysql":
+            # MySQL doesn't support DELETE with JOIN, so we need to do it in two steps
+            ids = session.scalars(ids).all()
         session.execute(
             delete(Trigger).where(Trigger.id.in_(ids)).execution_options(synchronize_session=False)
         )