--- 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")