From aed4da2722c0ee06cf4644a75f0b99ad178b924b Mon Sep 17 00:00:00 2001 From: Ishaan Date: Tue, 11 Aug 2026 15:15:09 +0530 Subject: [PATCH 1/3] Add table for intermediate output storeage for fieldMapping --- ...create_intermediate_field_mapping_table.py | 33 +++++++++++++++++++ 1 file changed, 33 insertions(+) create mode 100644 lending-poc/alembic/versions/1a2b3c4d5e6f_create_intermediate_field_mapping_table.py diff --git a/lending-poc/alembic/versions/1a2b3c4d5e6f_create_intermediate_field_mapping_table.py b/lending-poc/alembic/versions/1a2b3c4d5e6f_create_intermediate_field_mapping_table.py new file mode 100644 index 0000000..5b09d83 --- /dev/null +++ b/lending-poc/alembic/versions/1a2b3c4d5e6f_create_intermediate_field_mapping_table.py @@ -0,0 +1,33 @@ +"""create intermediate_field_mapping table + +Revision ID: 1a2b3c4d5e6f +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 = '1a2b3c4d5e6f' +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('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') From 7df9b9ee702e5871324231a48f7660b840d6b4ac Mon Sep 17 00:00:00 2001 From: Ishaan Date: Tue, 11 Aug 2026 15:43:33 +0530 Subject: [PATCH 2/3] Add a foreign key for tracking each document mapping --- .../1a2b3c4d5e6f_create_intermediate_field_mapping_table.py | 1 + 1 file changed, 1 insertion(+) diff --git a/lending-poc/alembic/versions/1a2b3c4d5e6f_create_intermediate_field_mapping_table.py b/lending-poc/alembic/versions/1a2b3c4d5e6f_create_intermediate_field_mapping_table.py index 5b09d83..6c384e5 100644 --- a/lending-poc/alembic/versions/1a2b3c4d5e6f_create_intermediate_field_mapping_table.py +++ b/lending-poc/alembic/versions/1a2b3c4d5e6f_create_intermediate_field_mapping_table.py @@ -22,6 +22,7 @@ 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), From 44fe8b7026ac201acef83035073c24a7c4e9ee68 Mon Sep 17 00:00:00 2001 From: Ishaan Bhela Date: Thu, 13 Aug 2026 14:52:55 +0530 Subject: [PATCH 3/3] Rename migration to match standard migration format --- ...ble.py => 0006_create_intermediate_field_mapping_table.py} | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) rename lending-poc/alembic/versions/{1a2b3c4d5e6f_create_intermediate_field_mapping_table.py => 0006_create_intermediate_field_mapping_table.py} (88%) diff --git a/lending-poc/alembic/versions/1a2b3c4d5e6f_create_intermediate_field_mapping_table.py b/lending-poc/alembic/versions/0006_create_intermediate_field_mapping_table.py similarity index 88% rename from lending-poc/alembic/versions/1a2b3c4d5e6f_create_intermediate_field_mapping_table.py rename to lending-poc/alembic/versions/0006_create_intermediate_field_mapping_table.py index 6c384e5..0608076 100644 --- a/lending-poc/alembic/versions/1a2b3c4d5e6f_create_intermediate_field_mapping_table.py +++ b/lending-poc/alembic/versions/0006_create_intermediate_field_mapping_table.py @@ -1,6 +1,6 @@ """create intermediate_field_mapping table -Revision ID: 1a2b3c4d5e6f +Revision ID: 0006_create_intermediate_field_mapping_table Revises: Create Date: 2026-08-11 15:05:00.000000 @@ -12,7 +12,7 @@ from sqlalchemy.dialects import postgresql # revision identifiers, used by Alembic. -revision: str = '1a2b3c4d5e6f' +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