updated authentication of instances
This commit is contained in:
24
migrations/versions/761908f0cacf_merge_heads.py
Normal file
24
migrations/versions/761908f0cacf_merge_heads.py
Normal file
@@ -0,0 +1,24 @@
|
||||
"""merge heads
|
||||
|
||||
Revision ID: 761908f0cacf
|
||||
Revises: 4ee23cb29001, add_connection_token
|
||||
Create Date: 2025-06-09 13:57:17.650231
|
||||
|
||||
"""
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision = '761908f0cacf'
|
||||
down_revision = ('4ee23cb29001', 'add_connection_token')
|
||||
branch_labels = None
|
||||
depends_on = None
|
||||
|
||||
|
||||
def upgrade():
|
||||
pass
|
||||
|
||||
|
||||
def downgrade():
|
||||
pass
|
||||
24
migrations/versions/add_connection_token.py
Normal file
24
migrations/versions/add_connection_token.py
Normal file
@@ -0,0 +1,24 @@
|
||||
"""add connection_token column
|
||||
|
||||
Revision ID: add_connection_token
|
||||
Revises: fix_updated_at_trigger
|
||||
Create Date: 2024-03-19 13:00:00.000000
|
||||
|
||||
"""
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision = 'add_connection_token'
|
||||
down_revision = 'fix_updated_at_trigger'
|
||||
branch_labels = None
|
||||
depends_on = None
|
||||
|
||||
|
||||
def upgrade():
|
||||
op.add_column('instances', sa.Column('connection_token', sa.String(64), nullable=True, unique=True))
|
||||
|
||||
|
||||
def downgrade():
|
||||
op.drop_column('instances', 'connection_token')
|
||||
@@ -7,6 +7,7 @@ Create Date: 2024-03-19 11:00:00.000000
|
||||
"""
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
from sqlalchemy import text
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
@@ -17,7 +18,18 @@ depends_on = None
|
||||
|
||||
|
||||
def upgrade():
|
||||
op.add_column('instances', sa.Column('status_details', sa.Text(), nullable=True))
|
||||
# Check if column exists before adding
|
||||
conn = op.get_bind()
|
||||
result = conn.execute(text("""
|
||||
SELECT EXISTS (
|
||||
SELECT FROM information_schema.columns
|
||||
WHERE table_name = 'instances' AND column_name = 'status_details'
|
||||
);
|
||||
"""))
|
||||
exists = result.scalar()
|
||||
|
||||
if not exists:
|
||||
op.add_column('instances', sa.Column('status_details', sa.Text(), nullable=True))
|
||||
|
||||
|
||||
def downgrade():
|
||||
|
||||
Reference in New Issue
Block a user