Mercurial > libervia-backend
diff libervia/backend/memory/migration/versions/8974efc51d22_create_tables_for_pubsub_caching.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/8974efc51d22_create_tables_for_pubsub_caching.py Tue Jun 18 12:06:45 2024 +0200 +++ b/libervia/backend/memory/migration/versions/8974efc51d22_create_tables_for_pubsub_caching.py Wed Jun 19 18:44:57 2024 +0200 @@ -5,53 +5,93 @@ Create Date: 2021-07-27 16:38:54.658212 """ + from alembic import op import sqlalchemy as sa from libervia.backend.memory.sqla_mapping import JID, Xml # revision identifiers, used by Alembic. -revision = '8974efc51d22' -down_revision = '602caf848068' +revision = "8974efc51d22" +down_revision = "602caf848068" branch_labels = None depends_on = None def upgrade(): # ### commands auto generated by Alembic - please adjust! ### - op.create_table('pubsub_nodes', - sa.Column('id', sa.Integer(), nullable=False), - sa.Column('profile_id', sa.Integer(), nullable=True), - sa.Column('service', JID(), nullable=True), - sa.Column('name', sa.Text(), nullable=False), - sa.Column('subscribed', sa.Boolean(create_constraint=True, name='subscribed_bool'), nullable=False), - sa.Column('analyser', sa.Text(), nullable=True), - sa.Column('sync_state', sa.Enum('IN_PROGRESS', 'COMPLETED', 'ERROR', 'NO_SYNC', name='sync_state', create_constraint=True), nullable=True), - sa.Column('sync_state_updated', sa.Float(), nullable=False), - sa.Column('type', sa.Text(), nullable=True), - sa.Column('subtype', sa.Text(), nullable=True), - sa.Column('extra', sa.JSON(), nullable=True), - sa.ForeignKeyConstraint(['profile_id'], ['profiles.id'], name=op.f('fk_pubsub_nodes_profile_id_profiles'), ondelete='CASCADE'), - sa.PrimaryKeyConstraint('id', name=op.f('pk_pubsub_nodes')), - sa.UniqueConstraint('profile_id', 'service', 'name', name=op.f('uq_pubsub_nodes_profile_id')) + op.create_table( + "pubsub_nodes", + sa.Column("id", sa.Integer(), nullable=False), + sa.Column("profile_id", sa.Integer(), nullable=True), + sa.Column("service", JID(), nullable=True), + sa.Column("name", sa.Text(), nullable=False), + sa.Column( + "subscribed", + sa.Boolean(create_constraint=True, name="subscribed_bool"), + nullable=False, + ), + sa.Column("analyser", sa.Text(), nullable=True), + sa.Column( + "sync_state", + sa.Enum( + "IN_PROGRESS", + "COMPLETED", + "ERROR", + "NO_SYNC", + name="sync_state", + create_constraint=True, + ), + nullable=True, + ), + sa.Column("sync_state_updated", sa.Float(), nullable=False), + sa.Column("type", sa.Text(), nullable=True), + sa.Column("subtype", sa.Text(), nullable=True), + sa.Column("extra", sa.JSON(), nullable=True), + sa.ForeignKeyConstraint( + ["profile_id"], + ["profiles.id"], + name=op.f("fk_pubsub_nodes_profile_id_profiles"), + ondelete="CASCADE", + ), + sa.PrimaryKeyConstraint("id", name=op.f("pk_pubsub_nodes")), + sa.UniqueConstraint( + "profile_id", "service", "name", name=op.f("uq_pubsub_nodes_profile_id") + ), ) - op.create_table('pubsub_items', - sa.Column('id', sa.Integer(), nullable=False), - sa.Column('node_id', sa.Integer(), nullable=False), - sa.Column('name', sa.Text(), nullable=False), - sa.Column('data', Xml(), nullable=False), - sa.Column('created', sa.DateTime(), server_default=sa.text('(CURRENT_TIMESTAMP)'), nullable=False), - sa.Column('updated', sa.DateTime(), server_default=sa.text('(CURRENT_TIMESTAMP)'), nullable=False), - sa.Column('parsed', sa.JSON(), nullable=True), - sa.ForeignKeyConstraint(['node_id'], ['pubsub_nodes.id'], name=op.f('fk_pubsub_items_node_id_pubsub_nodes'), ondelete='CASCADE'), - sa.PrimaryKeyConstraint('id', name=op.f('pk_pubsub_items')), - sa.UniqueConstraint('node_id', 'name', name=op.f('uq_pubsub_items_node_id')) + op.create_table( + "pubsub_items", + sa.Column("id", sa.Integer(), nullable=False), + sa.Column("node_id", sa.Integer(), nullable=False), + sa.Column("name", sa.Text(), nullable=False), + sa.Column("data", Xml(), nullable=False), + sa.Column( + "created", + sa.DateTime(), + server_default=sa.text("(CURRENT_TIMESTAMP)"), + nullable=False, + ), + sa.Column( + "updated", + sa.DateTime(), + server_default=sa.text("(CURRENT_TIMESTAMP)"), + nullable=False, + ), + sa.Column("parsed", sa.JSON(), nullable=True), + sa.ForeignKeyConstraint( + ["node_id"], + ["pubsub_nodes.id"], + name=op.f("fk_pubsub_items_node_id_pubsub_nodes"), + ondelete="CASCADE", + ), + sa.PrimaryKeyConstraint("id", name=op.f("pk_pubsub_items")), + sa.UniqueConstraint("node_id", "name", name=op.f("uq_pubsub_items_node_id")), ) # ### end Alembic commands ### def downgrade(): # ### commands auto generated by Alembic - please adjust! ### - op.drop_table('pubsub_items') - op.drop_table('pubsub_nodes') + op.drop_table("pubsub_items") + op.drop_table("pubsub_nodes") # ### end Alembic commands ###