Skip to content

Commit eaf8547

Browse files
2 fixes (#174)
* dont drop model_id in metric_value column * add extra commit
1 parent 8bb6d75 commit eaf8547

File tree

2 files changed

+1
-10
lines changed

2 files changed

+1
-10
lines changed

nowcasting_datamodel/migrations/forecast/versions/caea7b5cf249_.py

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -21,20 +21,10 @@ def upgrade(): # noqa
2121
# ### commands auto generated by Alembic - please adjust! ###
2222

2323
op.add_column("metric_value", sa.Column("model_name", sa.String(), nullable=True))
24-
op.drop_index("ix_metric_value_model_id", table_name="metric_value")
25-
op.drop_constraint("metric_value_model_id_fkey", "metric_value", type_="foreignkey")
26-
op.drop_column("metric_value", "model_id")
2724
# ### end Alembic commands ###
2825

2926

3027
def downgrade(): # noqa
3128
# ### commands auto generated by Alembic - please adjust! ###
32-
op.add_column(
33-
"metric_value", sa.Column("model_id", sa.INTEGER(), autoincrement=False, nullable=True)
34-
)
35-
op.create_foreign_key(
36-
"metric_value_model_id_fkey", "metric_value", "model", ["model_id"], ["id"]
37-
)
38-
op.create_index("ix_metric_value_model_id", "metric_value", ["model_id"], unique=False)
3929
op.drop_column("metric_value", "model_name")
4030
# ### end Alembic commands ###

nowcasting_datamodel/save/update.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -80,6 +80,7 @@ def upsert(session: Session, model, rows: List[dict]):
8080

8181
stmt = stmt.on_conflict_do_update(index_elements=primary_keys, set_=update_dict)
8282
session.execute(stmt, rows)
83+
session.commit()
8384

8485

8586
def update_forecast_latest(

0 commit comments

Comments
 (0)