|
| 1 | +"""add_user_experiment_access_table |
| 2 | +
|
| 3 | +Revision ID: 46378c10f132 |
| 4 | +Revises: 6ccd4a4d9ca1 |
| 5 | +Create Date: 2026-05-04 13:23:27.122716 |
| 6 | +
|
| 7 | +""" |
| 8 | + |
| 9 | +from typing import Sequence, Union |
| 10 | + |
| 11 | +from alembic import op |
| 12 | +import sqlalchemy as sa |
| 13 | +from transformerlab.db.migration_utils import table_exists |
| 14 | + |
| 15 | + |
| 16 | +# revision identifiers, used by Alembic. |
| 17 | +revision: str = "46378c10f132" |
| 18 | +down_revision: Union[str, Sequence[str], None] = "6ccd4a4d9ca1" |
| 19 | +branch_labels: Union[str, Sequence[str], None] = None |
| 20 | +depends_on: Union[str, Sequence[str], None] = None |
| 21 | + |
| 22 | + |
| 23 | +def upgrade() -> None: |
| 24 | + connection = op.get_bind() |
| 25 | + if not table_exists(connection, "user_experiment_access"): |
| 26 | + op.create_table( |
| 27 | + "user_experiment_access", |
| 28 | + sa.Column("id", sa.Integer(), autoincrement=True, nullable=False), |
| 29 | + sa.Column("user_id", sa.String(), nullable=False), |
| 30 | + sa.Column("team_id", sa.String(), nullable=False), |
| 31 | + sa.Column("experiment_id", sa.String(), nullable=False), |
| 32 | + sa.Column( |
| 33 | + "last_opened_at", |
| 34 | + sa.DateTime(), |
| 35 | + server_default=sa.text("(CURRENT_TIMESTAMP)"), |
| 36 | + nullable=False, |
| 37 | + ), |
| 38 | + sa.PrimaryKeyConstraint("id"), |
| 39 | + sa.UniqueConstraint( |
| 40 | + "user_id", |
| 41 | + "team_id", |
| 42 | + "experiment_id", |
| 43 | + name="uq_user_experiment_access", |
| 44 | + ), |
| 45 | + ) |
| 46 | + op.create_index( |
| 47 | + "idx_user_experiment_access_user_team", |
| 48 | + "user_experiment_access", |
| 49 | + ["user_id", "team_id"], |
| 50 | + ) |
| 51 | + |
| 52 | + |
| 53 | +def downgrade() -> None: |
| 54 | + op.drop_index("idx_user_experiment_access_user_team", table_name="user_experiment_access", if_exists=True) |
| 55 | + op.drop_table("user_experiment_access", if_exists=True) |
0 commit comments