def upgrade()

in annotation/alembic/versions/4272d0a43ff1_agreement_score.py [0:0]

• 41 lines of code
• 1 McCabe index (conditional complexity)

def upgrade():
    # ### commands auto generated by Alembic - please adjust! ###
    op.create_table(
        "agreement_score",
        sa.Column(
            "annotator_id", postgresql.UUID(as_uuid=True), nullable=False
        ),
        sa.Column("job_id", sa.INTEGER(), nullable=False),
        sa.Column("task_id", sa.INTEGER(), nullable=False),
        sa.Column(
            "agreement_score",
            postgresql.JSONB(astext_type=sa.Text()),
            nullable=False,
        ),
        sa.ForeignKeyConstraint(
            ["annotator_id"],
            ["users.user_id"],
        ),
        sa.ForeignKeyConstraint(
            ["job_id"], ["jobs.job_id"], ondelete="cascade"
        ),
        sa.ForeignKeyConstraint(["task_id"], ["tasks.id"], ondelete="cascade"),
        sa.PrimaryKeyConstraint("task_id"),
    )
    op.create_table(
        "annotation_statistics",
        sa.Column("task_id", sa.INTEGER(), nullable=False),
        sa.Column(
            "event_type",
            postgresql.ENUM("opened", "closed", name="event_type"),
            nullable=False,
        ),
        sa.Column("created", sa.DateTime(), nullable=True),
        sa.Column("updated", sa.DateTime(), nullable=True),
        sa.Column(
            "additional_data",
            postgresql.JSONB(astext_type=sa.Text()),
            nullable=True,
        ),
        sa.ForeignKeyConstraint(["task_id"], ["tasks.id"], ondelete="cascade"),
        sa.PrimaryKeyConstraint("task_id"),
    )