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 <[email protected]> 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
