diff --git a/airflow/migrations/versions/852ae6c715af_add_rendered_task_instance_fields_table.py b/airflow/migrations/versions/852ae6c715af_add_rendered_task_instance_fields_table.py
index 60f70f3b600670..0e0205f40f55ce 100644
--- a/airflow/migrations/versions/852ae6c715af_add_rendered_task_instance_fields_table.py
+++ b/airflow/migrations/versions/852ae6c715af_add_rendered_task_instance_fields_table.py
@@ -46,7 +46,7 @@ def upgrade():
         # versions, check for the function existing.
         try:
             conn.execute("SELECT JSON_VALID(1)").fetchone()
-        except sa.exc.OperationalError:
+        except (sa.exc.OperationalError, sa.exc.ProgrammingError):
             json_type = sa.Text
 
     op.create_table(