(airflow) branch main updated: Add if_not_exists to index creation in migrations (#56328)

[vincbeck]

This is an automated email from the ASF dual-hosted git repository.

vincbeck 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 d0997c7824a Add if_not_exists to index creation in migrations (#56328)
d0997c7824a is described below

commit d0997c7824a1499f0e9c45406f86c9b10d56d3ce
Author: meher1993 <ckoll...@gmail.com>
AuthorDate: Thu Oct 2 14:21:30 2025 -0500

    Add if_not_exists to index creation in migrations (#56328)
---
 .../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 e281437c9c6..a7ad1301c4a 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",