Skip to content

Commit b0c92a7

Browse files
authored
Python node extension & step custom progress message (#184)
* Adds alembic file for new table * Merge conflicts * Submodule update
1 parent 0b3da76 commit b0c92a7

File tree

2 files changed

+54
-1
lines changed

2 files changed

+54
-1
lines changed
Lines changed: 53 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,53 @@
1+
"""Adds global websocket table
2+
3+
Revision ID: 754dd15f2c9c
4+
Revises: 7de3c19cddcf
5+
Create Date: 2024-02-16 06:33:18.628812
6+
7+
"""
8+
9+
from alembic import op
10+
import sqlalchemy as sa
11+
from sqlalchemy.dialects import postgresql
12+
13+
# revision identifiers, used by Alembic.
14+
revision = "754dd15f2c9c"
15+
down_revision = "7de3c19cddcf"
16+
branch_labels = None
17+
depends_on = None
18+
19+
20+
def upgrade():
21+
# ### commands auto generated by Alembic - please adjust! ###
22+
op.execute("create schema global")
23+
op.create_table(
24+
"websocket_access",
25+
sa.Column("id", postgresql.UUID(as_uuid=True), nullable=False),
26+
sa.Column("config", sa.JSON(), nullable=True),
27+
sa.Column("in_use", sa.Boolean(), nullable=True),
28+
sa.Column("created_at", sa.DateTime(), nullable=True),
29+
sa.Column("created_by", postgresql.UUID(as_uuid=True), nullable=True),
30+
sa.ForeignKeyConstraint(["created_by"], ["user.id"], ondelete="CASCADE"),
31+
sa.PrimaryKeyConstraint("id"),
32+
schema="global",
33+
)
34+
op.create_index(
35+
op.f("ix_global_websocket_access_created_by"),
36+
"websocket_access",
37+
["created_by"],
38+
unique=False,
39+
schema="global",
40+
)
41+
# ### end Alembic commands ###
42+
43+
44+
def downgrade():
45+
# ### commands auto generated by Alembic - please adjust! ###
46+
op.drop_index(
47+
op.f("ix_global_websocket_access_created_by"),
48+
table_name="websocket_access",
49+
schema="global",
50+
)
51+
op.drop_table("websocket_access", schema="global")
52+
op.execute("drop schema global")
53+
# ### end Alembic commands ###

0 commit comments

Comments
 (0)