From 2560795be2127a97fe89256431e67c7c813533f9 Mon Sep 17 00:00:00 2001 From: meher1993 Date: Thu, 2 Oct 2025 08:30:59 -0500 Subject: [PATCH] Add if_not_exists to index creation in migrations --- .../versions/0001_1_4_0_create_ab_tables_if_missing.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/providers/fab/src/airflow/providers/fab/migrations/versions/0001_1_4_0_create_ab_tables_if_missing.py b/providers/fab/src/airflow/providers/fab/migrations/versions/0001_1_4_0_create_ab_tables_if_missing.py index e281437c9c6e1..a7ad1301c4af2 100644 --- a/providers/fab/src/airflow/providers/fab/migrations/versions/0001_1_4_0_create_ab_tables_if_missing.py +++ b/providers/fab/src/airflow/providers/fab/migrations/versions/0001_1_4_0_create_ab_tables_if_missing.py @@ -139,8 +139,8 @@ def upgrade() -> None: if_not_exists=True, ) with op.batch_alter_table("ab_group_role", schema=None) as batch_op: - batch_op.create_index("idx_group_id", ["group_id"], unique=False) - batch_op.create_index("idx_group_role_id", ["role_id"], unique=False) + batch_op.create_index("idx_group_id", ["group_id"], unique=False, if_not_exists=True) + batch_op.create_index("idx_group_role_id", ["role_id"], unique=False, if_not_exists=True) op.create_table( "ab_permission_view", @@ -175,8 +175,8 @@ def upgrade() -> None: if_not_exists=True, ) with op.batch_alter_table("ab_user_group", schema=None) as batch_op: - batch_op.create_index("idx_user_group_id", ["group_id"], unique=False) - batch_op.create_index("idx_user_id", ["user_id"], unique=False) + batch_op.create_index("idx_user_group_id", ["group_id"], unique=False, if_not_exists=True) + batch_op.create_index("idx_user_id", ["user_id"], unique=False, if_not_exists=True) op.create_table( "ab_user_role",