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",