Delete dag_version table when downgrading the DB from the versioned Airflow

airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py

@@ -132,6 +132,9 @@ def upgrade():
 
 def downgrade():
     """Unapply add dag versioning."""
+    # Going down from here, the way we serialize DAG changes, so we need to delete the dag_version table
+    # which in turn deletes the serialized dag and dag code tables.
+    op.execute(sa.text("DELETE FROM dag_version"))
     with op.batch_alter_table("task_instance_history", schema=None) as batch_op:
         batch_op.drop_column("dag_version_id")
 

docs/apache-airflow/img/airflow_erd.sha256

@@ -1 +1 @@
-5042271e47bcf1160477200adae4c42ce1cecacf5cbbe7e334d6268debe857fb
+aa9e2e5b2a52af1e92bc876727ad5e8958e291315096fc5249a9afa2c21a5d06