This is an automated email from the ASF dual-hosted git repository.
weilee pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 7bcd84b1c59 fix(migration): fix dataset to asset migration typo
(#43245)
7bcd84b1c59 is described below
commit 7bcd84b1c59ea57f0ab532fb5f110af4e26629b9
Author: Wei Lee <[email protected]>
AuthorDate: Wed Oct 23 14:16:28 2024 +0800
fix(migration): fix dataset to asset migration typo (#43245)
* fix(migration): fix dataset to asset migration typo
* fix(migrations): dsdar_dag_id_fkey was accidentally named as
dsdar_dag_fkey. thus, we need to use dsdar_dag_fkey in migration files
---
.../0026_2_10_0_dag_schedule_dataset_alias_reference.py | 4 ++--
.../migrations/versions/0040_3_0_0_rename_dataset_as_asset.py | 10 +++++-----
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
3 files changed, 8 insertions(+), 8 deletions(-)
diff --git
a/airflow/migrations/versions/0026_2_10_0_dag_schedule_dataset_alias_reference.py
b/airflow/migrations/versions/0026_2_10_0_dag_schedule_dataset_alias_reference.py
index a577a3eb781..6d2a25d49e3 100644
---
a/airflow/migrations/versions/0026_2_10_0_dag_schedule_dataset_alias_reference.py
+++
b/airflow/migrations/versions/0026_2_10_0_dag_schedule_dataset_alias_reference.py
@@ -52,13 +52,13 @@ def upgrade():
sa.ForeignKeyConstraint(
("alias_id",),
["dataset_alias.id"],
- name="dsdar_dataset_fkey",
+ name="dsdar_dataset_alias_fkey",
ondelete="CASCADE",
),
sa.ForeignKeyConstraint(
columns=("dag_id",),
refcolumns=["dag.dag_id"],
- name="dsdar_dag_id_fkey",
+ name="dsdar_dag_fkey",
ondelete="CASCADE",
),
sa.PrimaryKeyConstraint("alias_id", "dag_id", name="dsdar_pkey"),
diff --git a/airflow/migrations/versions/0040_3_0_0_rename_dataset_as_asset.py
b/airflow/migrations/versions/0040_3_0_0_rename_dataset_as_asset.py
index 70261b75c7b..ffe4fe7b834 100644
--- a/airflow/migrations/versions/0040_3_0_0_rename_dataset_as_asset.py
+++ b/airflow/migrations/versions/0040_3_0_0_rename_dataset_as_asset.py
@@ -193,8 +193,8 @@ def upgrade():
)
with op.batch_alter_table("dag_schedule_asset_alias_reference",
schema=None) as batch_op:
- batch_op.drop_constraint("dsdar_dataset_fkey", type_="foreignkey")
- batch_op.drop_constraint("dsdar_dag_id_fkey", type_="foreignkey")
+ batch_op.drop_constraint("dsdar_dataset_alias_fkey",
type_="foreignkey")
+ batch_op.drop_constraint("dsdar_dag_fkey", type_="foreignkey")
_rename_pk_constraint(
batch_op=batch_op,
@@ -218,7 +218,7 @@ def upgrade():
ondelete="CASCADE",
)
batch_op.create_foreign_key(
- constraint_name="dsaar_dag_fkey",
+ constraint_name="dsaar_dag_id_fkey",
referent_table="dag",
local_cols=["dag_id"],
remote_cols=["dag_id"],
@@ -512,14 +512,14 @@ def downgrade():
)
batch_op.create_foreign_key(
- constraint_name="dsdar_dataset_fkey",
+ constraint_name="dsdar_dataset_alias_fkey",
referent_table="dataset_alias",
local_cols=["alias_id"],
remote_cols=["id"],
ondelete="CASCADE",
)
batch_op.create_foreign_key(
- constraint_name="dsdar_dag_id_fkey",
+ constraint_name="dsdar_dag_fkey",
referent_table="dag",
local_cols=["dag_id"],
remote_cols=["dag_id"],
diff --git a/docs/apache-airflow/img/airflow_erd.sha256
b/docs/apache-airflow/img/airflow_erd.sha256
index 7adc054f61d..c67b2d5abce 100644
--- a/docs/apache-airflow/img/airflow_erd.sha256
+++ b/docs/apache-airflow/img/airflow_erd.sha256
@@ -1 +1 @@
-e1e32de9983ee02f268010485363ec222927c64e13be142761fc2b9f9cf33090
\ No newline at end of file
+fa87dd4d48e630a5e523157bebb8710fcc4cee9527b735ac67ec1274d5858bce
\ No newline at end of file
