Coverage for mindsdb / migrations / versions / 2023-07-13_a57506731839_triggers.py: 69%

1"""triggers 

2 

3Revision ID: a57506731839 

4Revises: 607709e1615b 

5Create Date: 2023-07-13 18:24:59.186856 

6 

7""" 

8from alembic import op 

9import sqlalchemy as sa 

10import mindsdb.interfaces.storage.db # noqa 

11 

12revision = 'a57506731839' 

13down_revision = '607709e1615b' 

14branch_labels = None 

15depends_on = None 

16 

17 

18def upgrade(): 

19 # ### commands auto generated by Alembic - please adjust! ### 

20 op.create_table( 

21 'tasks', 

22 sa.Column('id', sa.Integer(), nullable=False), 

23 sa.Column('company_id', sa.Integer(), nullable=True), 

24 sa.Column('user_class', sa.Integer(), nullable=True), 

25 sa.Column('object_type', sa.String(), nullable=False), 

26 sa.Column('object_id', sa.Integer(), nullable=False), 

27 sa.Column('last_error', sa.String(), nullable=True), 

28 sa.Column('active', sa.Boolean(), nullable=True), 

29 sa.Column('reload', sa.Boolean(), nullable=True), 

30 sa.Column('run_by', sa.String(), nullable=True), 

31 sa.Column('alive_time', sa.DateTime(timezone=True), nullable=True), 

32 sa.Column('updated_at', sa.DateTime(), nullable=True), 

33 sa.Column('created_at', sa.DateTime(), nullable=True), 

34 sa.PrimaryKeyConstraint('id') 

35 ) 

36 op.create_table( 

37 'triggers', 

38 sa.Column('id', sa.Integer(), nullable=False), 

39 sa.Column('name', sa.String(), nullable=False), 

40 sa.Column('project_id', sa.Integer(), nullable=False), 

41 sa.Column('database_id', sa.Integer(), nullable=False), 

42 sa.Column('table_name', sa.String(), nullable=False), 

43 sa.Column('columns', sa.String(), nullable=True), 

44 sa.Column('query_str', sa.String(), nullable=False), 

45 sa.Column('updated_at', sa.DateTime(), nullable=True), 

46 sa.Column('created_at', sa.DateTime(), nullable=True), 

47 sa.PrimaryKeyConstraint('id') 

48 ) 

49 

50 

51def downgrade(): 

52 op.drop_table('triggers') 

53 op.drop_table('tasks') 

54 # ### end Alembic commands ###