1 """Add `sender` to `FlowRunInput`
2
3 Revision ID: c63a0a6dc787
4 Revises: 35659cc49969
5 Create Date: 2024-01-05 10:10:41.226754
6
7 """
8
9 import sqlalchemy as sa 1 ctx 1a
10 from alembic import op 1 ctx 1a
11
12 # revision identifiers, used by Alembic.
13 revision = "c63a0a6dc787" 1 ctx 1a
14 down_revision = "35659cc49969" 1 ctx 1a
15 branch_labels = None 1 ctx 1a
16 depends_on = None 1 ctx 1a
17
18
19 def upgrade ( ) : 1 ctx 1a
20 with op . batch_alter_table ( "flow_run_input" , schema = None ) as batch_op : 1 ctx 1a
21 batch_op . add_column ( sa . Column ( "sender" , sa . String ( ) , nullable = True ) ) 1 ctx 1a
22
23
24 def downgrade ( ) : 1 ctx 1a
25 with op . batch_alter_table ( "flow_run_input" , schema = None ) as batch_op :
26 batch_op . drop_column ( "sender" )