You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2024/11/06 09:29:04 UTC
(airflow) 01/02: Revert "Delete the Serialized Dag and DagCode before DagVersion migration (#43700)"
This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch attempt-to-revert-dag-versioning
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 07f9392f25d3ae3dac6b57b5bb661081e2e6bfce
Author: Jarek Potiuk <ja...@potiuk.com>
AuthorDate: Wed Nov 6 10:28:26 2024 +0100
Revert "Delete the Serialized Dag and DagCode before DagVersion migration (#43700)"
This reverts commit 438f71df8d8621acdc3ddc6e6d3f06a51b66b8cb.
---
airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py | 7 -------
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
2 files changed, 1 insertion(+), 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
index ca685ae4e07..12ffc174c75 100644
--- 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 @@ depends_on = None
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
index 48700f5604e..c8963880f84 100644
--- a/docs/apache-airflow/img/airflow_erd.sha256
+++ b/docs/apache-airflow/img/airflow_erd.sha256
@@ -1 +1 @@
-4adae6a26c3378a5da5468eecfcbd27948c2af285a8dcf12ff8c3969e19f19f7
\ No newline at end of file
+f997746cdee45147831f81bcd2d43ec3ca45d7429afa691e385104987ed51d88
\ No newline at end of file