From 6809288e025dd7e20d9081db8c36e49fe3460f2c Mon Sep 17 00:00:00 2001 From: mfonsecaOEF Date: Wed, 22 May 2024 08:23:56 -0300 Subject: [PATCH 1/2] fix:column_types --- ...7f44_fix_column_type_activity_emissions.py | 36 +++++++++++++++++++ 1 file changed, 36 insertions(+) create mode 100644 global-api/migrations/versions/c360f7e67f44_fix_column_type_activity_emissions.py diff --git a/global-api/migrations/versions/c360f7e67f44_fix_column_type_activity_emissions.py b/global-api/migrations/versions/c360f7e67f44_fix_column_type_activity_emissions.py new file mode 100644 index 000000000..69da3f420 --- /dev/null +++ b/global-api/migrations/versions/c360f7e67f44_fix_column_type_activity_emissions.py @@ -0,0 +1,36 @@ +"""fix_column_type_activity_emissions + +Revision ID: c360f7e67f44 +Revises: 949c5b9cc18d +Create Date: 2024-05-22 08:21:13.727742 + +""" +from typing import Sequence, Union + +from alembic import op +import sqlalchemy as sa + + +# revision identifiers, used by Alembic. +revision: str = 'c360f7e67f44' +down_revision: Union[str, None] = '949c5b9cc18d' +branch_labels: Union[str, Sequence[str], None] = None +depends_on: Union[str, Sequence[str], None] = None + + +def upgrade() -> None: + op.alter_column('country_code', 'activity_value', + existing_type=sa.String(), + type_=sa.Float) + op.alter_column('country_code', 'emissions_value', + existing_type=sa.String(), + type_=sa.Float) + + +def downgrade() -> None: + op.alter_column('country_code', 'activity_value', + existing_type=sa.Float, + type_=sa.String()) + op.alter_column('country_code', 'emissions_value', + existing_type=sa.Float, + type_=sa.String()) From d095205e28f818c8e115631aa6c7420a3ff9f52a Mon Sep 17 00:00:00 2001 From: Amanda Eames Date: Wed, 22 May 2024 08:56:04 -0300 Subject: [PATCH 2/2] adding caasting of values to change type --- ...e67f44_fix_column_type_activity_emissions.py | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) diff --git a/global-api/migrations/versions/c360f7e67f44_fix_column_type_activity_emissions.py b/global-api/migrations/versions/c360f7e67f44_fix_column_type_activity_emissions.py index 69da3f420..78c0d84d9 100644 --- a/global-api/migrations/versions/c360f7e67f44_fix_column_type_activity_emissions.py +++ b/global-api/migrations/versions/c360f7e67f44_fix_column_type_activity_emissions.py @@ -21,16 +21,19 @@ def upgrade() -> None: op.alter_column('country_code', 'activity_value', existing_type=sa.String(), - type_=sa.Float) + type_=sa.Float(), + postgresql_using='activity_value::double precision') op.alter_column('country_code', 'emissions_value', existing_type=sa.String(), - type_=sa.Float) - + type_=sa.Float(), + postgresql_using='emissions_value::double precision') def downgrade() -> None: op.alter_column('country_code', 'activity_value', - existing_type=sa.Float, - type_=sa.String()) + existing_type=sa.Float(), + type_=sa.String(), + postgresql_using='activity_value::text') op.alter_column('country_code', 'emissions_value', - existing_type=sa.Float, - type_=sa.String()) + existing_type=sa.Float(), + type_=sa.String(), + postgresql_using='emissions_value::text')