1 """Add job_variables column to flow-runs
2
3 Revision ID: 342220764f0b
4 Revises: 265eb1a2da4c
5 Create Date: 2024-03-05 11:52:58.330563
6
7 """
8
9 import sqlalchemy as sa 1 ctx 1a
10 from alembic import op 1 ctx 1a
11 from sqlalchemy import Text 1 ctx 1a
12
13 import prefect 1 ctx 1a
14
15 # revision identifiers, used by Alembic.
16 revision = "342220764f0b" 1 ctx 1a
17 down_revision = "265eb1a2da4c" 1 ctx 1a
18 branch_labels = None 1 ctx 1a
19 depends_on = None 1 ctx 1a
20
21
22 def upgrade ( ) : 1 ctx 1a
23 op . add_column ( 1 ctx 1a
24 "flow_run" ,
25 sa . Column (
26 "job_variables" ,
27 prefect . server . utilities . database . JSON ( astext_type = Text ( ) ) ,
28 server_default = "{}" ,
29 nullable = True ,
30 ) ,
31 )
32
33
34 def downgrade ( ) : 1 ctx 1a
35 op . drop_column ( "flow_run" , "job_variables" )