1 """add_deployment_version_to_flow_run
2
3 Revision ID: 8644a9595a08
4 Revises: 07ed05dfd4ec
5 Create Date: 2024-04-02 11:45:38.210743
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 = "8644a9595a08" 1 ctx 1a
14 down_revision = "07ed05dfd4ec" 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 op . add_column ( 1 ctx 1a
21 "flow_run" , sa . Column ( "deployment_version" , sa . String ( ) , nullable = True )
22 )
23 op . create_index ( 1 ctx 1a
24 op . f ( "ix_flow_run__deployment_version" ) ,
25 "flow_run" ,
26 [ "deployment_version" ] ,
27 unique = False ,
28 )
29
30
31 def downgrade ( ) : 1 ctx 1a
32 op . drop_index ( op . f ( "ix_flow_run__deployment_version" ) , table_name = "flow_run" )
33 op . drop_column ( "flow_run" , "deployment_version" )