diff --git a/alembic/versions/15f133dd208b_adds_etl_new_attributes.py b/alembic/versions/15f133dd208b_adds_etl_new_attributes.py new file mode 100644 index 00000000..e1a7d310 --- /dev/null +++ b/alembic/versions/15f133dd208b_adds_etl_new_attributes.py @@ -0,0 +1,59 @@ +"""adds etl new attributes + +Revision ID: 15f133dd208b +Revises: 04cd434ed6eb +Create Date: 2025-12-11 22:34:07.966633 + +""" + +from alembic import op +import sqlalchemy as sa + + +# revision identifiers, used by Alembic. +revision = "15f133dd208b" +down_revision = "04cd434ed6eb" +branch_labels = None +depends_on = None + + +def upgrade(): + # ### commands auto generated by Alembic - please adjust! ### + op.add_column( + "etl_task", + sa.Column("full_config_hash", sa.String(), nullable=True), + schema="global", + ) + op.add_column( + "etl_task", sa.Column("is_stale", sa.Boolean(), nullable=True), schema="global" + ) + op.add_column( + "etl_task", sa.Column("llm_ops", sa.JSON(), nullable=True), schema="global" + ) + op.add_column( + "etl_task", + sa.Column("updated_at", sa.DateTime(), nullable=True), + schema="global", + ) + op.create_index( + op.f("ix_global_etl_task_full_config_hash"), + "etl_task", + ["full_config_hash"], + unique=False, + schema="global", + ) + # ### end Alembic commands ### + + +def downgrade(): + # ### commands auto generated by Alembic - please adjust! ### + op.drop_index( + op.f("ix_global_etl_task_full_config_hash"), + table_name="etl_task", + schema="global", + ) + op.drop_column("etl_task", "updated_at", schema="global") + op.drop_column("etl_task", "llm_ops", schema="global") + op.drop_column("etl_task", "is_stale", schema="global") + op.drop_column("etl_task", "full_config_hash", schema="global") + # ### end Alembic commands ### diff --git a/submodules/model b/submodules/model index 67d2713a..144dde2a 160000 --- a/submodules/model +++ b/submodules/model @@ -1 +1 @@ -Subproject commit 67d2713ad19a2f4e4b676c5673f0ac3bfec0d1b3 +Subproject commit 144dde2af3d2c940ee13df161194c4aa76a0c197