Phase 3: Expensive computations — API wiring

alembic/versions/20260220_83ceeb90bd74_add_constituency_impacts_table.py

@@ -0,0 +1,50 @@
+"""add_constituency_impacts_table
+
+Revision ID: 83ceeb90bd74
+Revises: a5e4144467e5
+Create Date: 2026-02-20 21:44:14.780195
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+import sqlmodel
+
+
+# revision identifiers, used by Alembic.
+revision: str = '83ceeb90bd74'
+down_revision: Union[str, Sequence[str], None] = 'a5e4144467e5'
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    """Upgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.create_table('constituency_impacts',
+    sa.Column('baseline_simulation_id', sa.Uuid(), nullable=False),
+    sa.Column('reform_simulation_id', sa.Uuid(), nullable=False),
+    sa.Column('report_id', sa.Uuid(), nullable=True),
+    sa.Column('constituency_code', sqlmodel.sql.sqltypes.AutoString(), nullable=False),
+    sa.Column('constituency_name', sqlmodel.sql.sqltypes.AutoString(), nullable=False),
+    sa.Column('x', sa.Integer(), nullable=False),
+    sa.Column('y', sa.Integer(), nullable=False),
+    sa.Column('average_household_income_change', sa.Float(), nullable=False),
+    sa.Column('relative_household_income_change', sa.Float(), nullable=False),
+    sa.Column('population', sa.Float(), nullable=False),
+    sa.Column('id', sa.Uuid(), nullable=False),
+    sa.Column('created_at', sa.DateTime(), nullable=False),
+    sa.ForeignKeyConstraint(['baseline_simulation_id'], ['simulations.id'], ),
+    sa.ForeignKeyConstraint(['reform_simulation_id'], ['simulations.id'], ),
+    sa.ForeignKeyConstraint(['report_id'], ['reports.id'], ),
+    sa.PrimaryKeyConstraint('id')
+    )
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    """Downgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_table('constituency_impacts')
+    # ### end Alembic commands ###

alembic/versions/20260220_8d54837f0fcd_add_decile_type_to_intra_decile_impacts.py

@@ -0,0 +1,33 @@
+"""add_decile_type_to_intra_decile_impacts
+
+Revision ID: 8d54837f0fcd
+Revises: a4ee5758d272
+Create Date: 2026-02-20 22:50:00.125733
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+import sqlmodel
+
+
+# revision identifiers, used by Alembic.
+revision: str = '8d54837f0fcd'
+down_revision: Union[str, Sequence[str], None] = 'a4ee5758d272'
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    """Upgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.add_column('intra_decile_impacts', sa.Column('decile_type', sqlmodel.sql.sqltypes.AutoString(), server_default='income', nullable=False))
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    """Downgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column('intra_decile_impacts', 'decile_type')
+    # ### end Alembic commands ###

alembic/versions/20260220_a4ee5758d272_add_local_authority_impacts_table.py

@@ -0,0 +1,50 @@
+"""add_local_authority_impacts_table
+
+Revision ID: a4ee5758d272
+Revises: 83ceeb90bd74
+Create Date: 2026-02-20 22:20:00.037965
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+import sqlmodel
+
+
+# revision identifiers, used by Alembic.
+revision: str = 'a4ee5758d272'
+down_revision: Union[str, Sequence[str], None] = '83ceeb90bd74'
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    """Upgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.create_table('local_authority_impacts',
+    sa.Column('baseline_simulation_id', sa.Uuid(), nullable=False),
+    sa.Column('reform_simulation_id', sa.Uuid(), nullable=False),
+    sa.Column('report_id', sa.Uuid(), nullable=True),
+    sa.Column('local_authority_code', sqlmodel.sql.sqltypes.AutoString(), nullable=False),
+    sa.Column('local_authority_name', sqlmodel.sql.sqltypes.AutoString(), nullable=False),
+    sa.Column('x', sa.Integer(), nullable=False),
+    sa.Column('y', sa.Integer(), nullable=False),
+    sa.Column('average_household_income_change', sa.Float(), nullable=False),
+    sa.Column('relative_household_income_change', sa.Float(), nullable=False),
+    sa.Column('population', sa.Float(), nullable=False),
+    sa.Column('id', sa.Uuid(), nullable=False),
+    sa.Column('created_at', sa.DateTime(), nullable=False),
+    sa.ForeignKeyConstraint(['baseline_simulation_id'], ['simulations.id'], ),
+    sa.ForeignKeyConstraint(['reform_simulation_id'], ['simulations.id'], ),
+    sa.ForeignKeyConstraint(['report_id'], ['reports.id'], ),
+    sa.PrimaryKeyConstraint('id')
+    )
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    """Downgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_table('local_authority_impacts')
+    # ### end Alembic commands ###

alembic/versions/20260220_a5e4144467e5_add_congressional_district_impacts_table.py

@@ -0,0 +1,48 @@
+"""add_congressional_district_impacts_table
+
+Revision ID: a5e4144467e5
+Revises: 75e5dca14603
+Create Date: 2026-02-20 20:52:53.243197
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision: str = 'a5e4144467e5'
+down_revision: Union[str, Sequence[str], None] = '75e5dca14603'
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    """Upgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.create_table('congressional_district_impacts',
+    sa.Column('baseline_simulation_id', sa.Uuid(), nullable=False),
+    sa.Column('reform_simulation_id', sa.Uuid(), nullable=False),
+    sa.Column('report_id', sa.Uuid(), nullable=True),
+    sa.Column('district_geoid', sa.Integer(), nullable=False),
+    sa.Column('state_fips', sa.Integer(), nullable=False),
+    sa.Column('district_number', sa.Integer(), nullable=False),
+    sa.Column('average_household_income_change', sa.Float(), nullable=False),
+    sa.Column('relative_household_income_change', sa.Float(), nullable=False),
+    sa.Column('population', sa.Float(), nullable=False),
+    sa.Column('id', sa.Uuid(), nullable=False),
+    sa.Column('created_at', sa.DateTime(), nullable=False),
+    sa.ForeignKeyConstraint(['baseline_simulation_id'], ['simulations.id'], ),
+    sa.ForeignKeyConstraint(['reform_simulation_id'], ['simulations.id'], ),
+    sa.ForeignKeyConstraint(['report_id'], ['reports.id'], ),
+    sa.PrimaryKeyConstraint('id')
+    )
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    """Downgrade schema."""
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_table('congressional_district_impacts')
+    # ### end Alembic commands ###