From e30767749e0d5e531bea295ede918032c6dd9288 Mon Sep 17 00:00:00 2001 From: codl Date: Fri, 4 Mar 2022 20:44:35 +0100 Subject: [PATCH] add celery checkin migration --- .../2a46ac75281c_add_celery_checkin.py | 29 +++++++++++++++++++ 1 file changed, 29 insertions(+) create mode 100644 migrations/versions/2a46ac75281c_add_celery_checkin.py diff --git a/migrations/versions/2a46ac75281c_add_celery_checkin.py b/migrations/versions/2a46ac75281c_add_celery_checkin.py new file mode 100644 index 0000000..52ed715 --- /dev/null +++ b/migrations/versions/2a46ac75281c_add_celery_checkin.py @@ -0,0 +1,29 @@ +"""add celery checkin + +Revision ID: 2a46ac75281c +Revises: 7b0e9b8e0887 +Create Date: 2022-03-04 20:43:58.455920 + +""" +from alembic import op +import sqlalchemy as sa + + +# revision identifiers, used by Alembic. +revision = '2a46ac75281c' +down_revision = '7b0e9b8e0887' +branch_labels = None +depends_on = None + + +def upgrade(): + op.create_table('worker_checkins', + sa.Column('created_at', sa.DateTime(timezone=True), server_default=sa.text('now()'), nullable=False), + sa.Column('updated_at', sa.DateTime(timezone=True), server_default=sa.text('now()'), nullable=False), + sa.Column('id', sa.Integer(), nullable=False), + sa.PrimaryKeyConstraint('id', name=op.f('pk_worker_checkins')) + ) + + +def downgrade(): + op.drop_table('worker_checkins')