Mercurial > libervia-backend
diff libervia/backend/memory/migration/versions/79e5f3313fa4_create_table_for_pubsub_subscriptions.py @ 4270:0d7bb4df2343
Reformatted code base using black.
author | Goffi <goffi@goffi.org> |
---|---|
date | Wed, 19 Jun 2024 18:44:57 +0200 |
parents | 4b842c1fb686 |
children |
line wrap: on
line diff
--- a/libervia/backend/memory/migration/versions/79e5f3313fa4_create_table_for_pubsub_subscriptions.py Tue Jun 18 12:06:45 2024 +0200 +++ b/libervia/backend/memory/migration/versions/79e5f3313fa4_create_table_for_pubsub_subscriptions.py Wed Jun 19 18:44:57 2024 +0200 @@ -5,29 +5,36 @@ Create Date: 2022-03-14 17:15:00.689871 """ + from alembic import op import sqlalchemy as sa from libervia.backend.memory.sqla_mapping import JID # revision identifiers, used by Alembic. -revision = '79e5f3313fa4' -down_revision = '129ac51807e4' +revision = "79e5f3313fa4" +down_revision = "129ac51807e4" branch_labels = None depends_on = None def upgrade(): - op.create_table('pubsub_subs', - sa.Column('id', sa.Integer(), nullable=False), - sa.Column('node_id', sa.Integer(), nullable=False), - sa.Column('subscriber', JID(), nullable=True), - sa.Column('state', sa.Enum('SUBSCRIBED', 'PENDING', name='state'), nullable=True), - sa.ForeignKeyConstraint(['node_id'], ['pubsub_nodes.id'], name=op.f('fk_pubsub_subs_node_id_pubsub_nodes'), ondelete='CASCADE'), - sa.PrimaryKeyConstraint('id', name=op.f('pk_pubsub_subs')), - sa.UniqueConstraint('node_id', 'subscriber', name=op.f('uq_pubsub_subs_node_id')) + op.create_table( + "pubsub_subs", + sa.Column("id", sa.Integer(), nullable=False), + sa.Column("node_id", sa.Integer(), nullable=False), + sa.Column("subscriber", JID(), nullable=True), + sa.Column("state", sa.Enum("SUBSCRIBED", "PENDING", name="state"), nullable=True), + sa.ForeignKeyConstraint( + ["node_id"], + ["pubsub_nodes.id"], + name=op.f("fk_pubsub_subs_node_id_pubsub_nodes"), + ondelete="CASCADE", + ), + sa.PrimaryKeyConstraint("id", name=op.f("pk_pubsub_subs")), + sa.UniqueConstraint("node_id", "subscriber", name=op.f("uq_pubsub_subs_node_id")), ) def downgrade(): - op.drop_table('pubsub_subs') + op.drop_table("pubsub_subs")