Skip to content

Commit

Permalink
Old DB enums in migrations. (#225)
Browse files Browse the repository at this point in the history
  • Loading branch information
vadim-zabolotniy committed Dec 21, 2022
1 parent 4798aaf commit 1252e43
Show file tree
Hide file tree
Showing 8 changed files with 12 additions and 22 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
Revises: bf6e28a49ebb
Create Date: 2022-08-22 08:23:37.268280
"""
import sqlalchemy as sa
from alembic import op
from sqlalchemy.dialects import postgresql

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,6 @@
"""
import sqlalchemy as sa
from alembic import op
from constants.roles import Roles
from sqlalchemy.dialects import postgresql


# revision identifiers, used by Alembic.
Expand All @@ -19,13 +17,13 @@


def upgrade() -> None:
user_roles = postgresql.ENUM(Roles, name='user_roles')
user_roles = sa.Enum('admin', 'operator', name='user_roles')
user_roles.create(op.get_bind(), checkfirst=True)

op.add_column('user', sa.Column('role', user_roles, nullable=True))


def downgrade() -> None:
op.drop_column('user', 'role')
user_roles = postgresql.ENUM(Roles, name='user_roles')
user_roles = sa.Enum('admin', 'operator', name='user_roles')
user_roles.drop(op.get_bind())
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
Revises: 9ee2947cff15
Create Date: 2022-10-04 19:24:52.838679
"""
import sqlalchemy as sa
from alembic import op


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
Revises: 69b38d90ab50
Create Date: 2022-10-17 16:39:59.985370
"""
import sqlalchemy as sa
from alembic import op


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,10 @@ def upgrade() -> None:
env={**system_environment, **{'PYTHONPATH': '.'}}
)
if response.returncode != 0:
error_message = response.stderr.decode()
if 'already exists' in error_message:
# It seems we trying to recreate existing Procrastinate DB entities.
return
raise RuntimeError(response.stderr.decode())


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,9 +7,6 @@
"""
import sqlalchemy as sa
from alembic import op
from sqlalchemy.dialects import postgresql

from constants.applications import ApplicationHealthStatuses


# revision identifiers, used by Alembic.
Expand All @@ -20,7 +17,7 @@


def upgrade() -> None:
statuses = postgresql.ENUM(ApplicationHealthStatuses, name='application_health_statuses')
statuses = sa.Enum('healthy', 'unhealthy', name='application_health_statuses')
statuses.create(op.get_bind(), checkfirst=True)
op.add_column('application', sa.Column('health', statuses, nullable=True))

Expand All @@ -31,5 +28,5 @@ def upgrade() -> None:

def downgrade() -> None:
op.drop_column('application', 'health')
statuses = postgresql.ENUM(ApplicationHealthStatuses, name='application_health_statuses')
statuses = sa.Enum('healthy', 'unhealthy', name='application_health_statuses')
statuses.drop(op.get_bind())
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,6 @@
"""
import sqlalchemy as sa
from alembic import op
from sqlalchemy.dialects import postgresql

from constants.events import EventCategory
from constants.events import EventSeverityLevel


# revision identifiers, used by Alembic.
Expand All @@ -21,8 +17,8 @@


def upgrade() -> None:
event_categories = postgresql.ENUM(EventCategory, name='event_categories')
event_severity_levels = postgresql.ENUM(EventSeverityLevel, name='event_severity_levels')
event_categories = sa.Enum('application', 'hook', 'organization', 'release', name='event_categories')
event_severity_levels = sa.Enum('debug', 'info', 'error', 'critical', name='event_severity_levels')
op.create_table(
'event',
sa.Column('id', sa.Integer(), nullable=False),
Expand All @@ -40,7 +36,7 @@ def upgrade() -> None:

def downgrade() -> None:
op.drop_table('event')
event_categories = postgresql.ENUM(EventCategory, name='event_categories')
event_categories = sa.Enum('application', 'hook', 'organization', 'release', name='event_categories')
event_categories.drop(op.get_bind())
event_severity_levels = postgresql.ENUM(EventSeverityLevel, name='event_severity_levels')
event_severity_levels = sa.Enum('debug', 'info', 'error', 'critical', name='event_severity_levels')
event_severity_levels.drop(op.get_bind())
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,7 @@
Revises: f6ed2d61f1fb
Create Date: 2022-11-17 12:43:42.865919
"""
import sqlalchemy as sa
from alembic import op
from sqlalchemy.dialects import postgresql

# revision identifiers, used by Alembic.
revision = 'e8700095ac3e'
Expand Down

0 comments on commit 1252e43

Please sign in to comment.