diff --git a/lending-poc/alembic/versions/0006_create_intermediate_field_mapping_table.py b/lending-poc/alembic/versions/0006_create_intermediate_field_mapping_table.py new file mode 100644 index 0000000..0608076 --- /dev/null +++ b/lending-poc/alembic/versions/0006_create_intermediate_field_mapping_table.py @@ -0,0 +1,34 @@ +"""create intermediate_field_mapping table + +Revision ID: 0006_create_intermediate_field_mapping_table +Revises: +Create Date: 2026-08-11 15:05:00.000000 + +""" +from typing import Sequence, Union + +from alembic import op +import sqlalchemy as sa +from sqlalchemy.dialects import postgresql + +# revision identifiers, used by Alembic. +revision: str = '0006_create_intermediate_field_mapping_table' +down_revision: Union[str, None] = None +branch_labels: Union[str, Sequence[str], None] = None +depends_on: Union[str, Sequence[str], None] = None + + +def upgrade() -> None: + op.create_table( + 'intermediate_field_mapping', + sa.Column('id', sa.Integer(), autoincrement=True, nullable=False), + sa.Column('case_id', sa.Integer(), nullable=False), + sa.Column('field_mapper_output', postgresql.JSONB(astext_type=sa.Text()), nullable=True), + sa.Column('processing_date', sa.DateTime(), nullable=True), + sa.Column('validated', sa.Boolean(), nullable=True), + sa.PrimaryKeyConstraint('id') + ) + + +def downgrade() -> None: + op.drop_table('intermediate_field_mapping')