Revert "Delete the Serialized Dag and DagCode before DagVersion migra…

…tion (#43700)" This reverts commit 438f71d.
apache · Nov 6, 2024 · 07f9392 · 07f9392
1 parent ef81cdf
commit 07f9392
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 8 deletions.
diff --git a/airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py b/airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py
@@ -44,15 +44,8 @@
 airflow_version = "3.0.0"
 
 
-def _delete_serdag_and_code():
-    op.execute(sa.text("DELETE FROM serialized_dag"))
-    op.execute(sa.text("DELETE FROM dag_code"))
-
-
 def upgrade():
     """Apply add dag versioning."""
-    # Before creating the dag_version table, we need to delete the existing serialized_dag and dag_code tables
-    _delete_serdag_and_code()
     op.create_table(
         "dag_version",
         sa.Column("id", UUIDType(binary=False), nullable=False),

diff --git a/docs/apache-airflow/img/airflow_erd.sha256 b/docs/apache-airflow/img/airflow_erd.sha256
@@ -1 +1 @@
-4adae6a26c3378a5da5468eecfcbd27948c2af285a8dcf12ff8c3969e19f19f7
+f997746cdee45147831f81bcd2d43ec3ca45d7429afa691e385104987ed51d88
Original file line number	Diff line number	Diff line change
		@@ -1 +1 @@
		4adae6a26c3378a5da5468eecfcbd27948c2af285a8dcf12ff8c3969e19f19f7
		f997746cdee45147831f81bcd2d43ec3ca45d7429afa691e385104987ed51d88