diff --git a/src/backend/langflow/alembic/versions/eb5866d51fd2_change_columns_to_be_nullable.py b/src/backend/langflow/alembic/versions/eb5866d51fd2_change_columns_to_be_nullable.py index 10d503e60..cb126c926 100644 --- a/src/backend/langflow/alembic/versions/eb5866d51fd2_change_columns_to_be_nullable.py +++ b/src/backend/langflow/alembic/versions/eb5866d51fd2_change_columns_to_be_nullable.py @@ -9,6 +9,7 @@ from typing import Sequence, Union from alembic import op import sqlalchemy as sa +from sqlalchemy import exc import sqlmodel # noqa: F401 # revision identifiers, used by Alembic. @@ -20,16 +21,21 @@ depends_on: Union[str, Sequence[str], None] = None def upgrade() -> None: # ### commands auto generated by Alembic - please adjust! ### + connection = op.get_bind() try: op.drop_table("flowstyle") with op.batch_alter_table("component", schema=None) as batch_op: batch_op.drop_index("ix_component_frontend_node_id") batch_op.drop_index("ix_component_name") + except exc.SQLAlchemyError: + connection.execute("ROLLBACK") except Exception: pass try: op.drop_table("component") + except exc.SQLAlchemyError: + connection.execute("ROLLBACK") except Exception: pass # ### end Alembic commands ###