"""create pipeline_retries table

Revision ID: d04cf726555d
Revises: <PASSWORD>
Create Date: 2021-09-02 13:04:36.053768

"""
from alembic import op
import sqlalchemy as sa


# revision identifiers, used by Alembic.
revision = 'd04cf726555d'
down_revision = '<PASSWORD>'
branch_labels = None
depends_on = None


def upgrade():
    op.create_table(
        'pipeline_retries',
        sa.Column('pipeline_id', sa.String, primary_key=True),
        sa.Column('number_of_error_statuses', sa.Integer, nullable=False)
    )
    op.create_foreign_key('fk_pipeline_retries_pipeline', 'pipeline_retries', 'pipelines', ['pipeline_id'], ['name'])


def downgrade():
    op.drop_table('pipeline_retries')

"""create pipeline_retries table

Revision ID: d04cf726555d
Revises: <PASSWORD>
Create Date: 2021-09-02 13:04:36.053768

"""
from alembic import op
import sqlalchemy as sa


# revision identifiers, used by Alembic.
revision = 'd04cf726555d'
down_revision = '<PASSWORD>'
branch_labels = None
depends_on = None


def upgrade():
    op.create_table(
        'pipeline_retries',
        sa.Column('pipeline_id', sa.String, primary_key=True),
        sa.Column('number_of_error_statuses', sa.Integer, nullable=False)
    )
    op.create_foreign_key('fk_pipeline_retries_pipeline', 'pipeline_retries', 'pipelines', ['pipeline_id'], ['name'])


def downgrade():
    op.drop_table('pipeline_retries')

create pipeline_retries table  Revision ID: d04cf726555d Revises: <PASSWORD> Create Date: 2021-09-02 13:04:36.053768 # revision identifiers, used by Alembic.