Skip to content

Commit 0b593a2

Browse files
dolfinusMTSOnGithub
authored andcommitted
Add migration for celery table changes
1 parent 6f0f924 commit 0b593a2

1 file changed

Lines changed: 27 additions & 0 deletions

File tree

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
# SPDX-FileCopyrightText: 2025-present MTS PJSC
2+
# SPDX-License-Identifier: Apache-2.0
3+
"""Add celery_*_date_done indexex
4+
5+
Revision ID: 0013
6+
Revises: 0012
7+
Create Date: 2026-04-02 11:06:44.293882
8+
9+
"""
10+
11+
from alembic import op
12+
13+
# revision identifiers, used by Alembic.
14+
revision = "0013"
15+
down_revision = "0012"
16+
branch_labels = None
17+
depends_on = None
18+
19+
20+
def upgrade() -> None:
21+
op.create_index(op.f("ix_celery_taskmeta_date_done"), "celery_taskmeta", ["date_done"], unique=False)
22+
op.create_index(op.f("ix_celery_tasksetmeta_date_done"), "celery_tasksetmeta", ["date_done"], unique=False)
23+
24+
25+
def downgrade() -> None:
26+
op.drop_index(op.f("ix_celery_tasksetmeta_date_done"), table_name="celery_tasksetmeta")
27+
op.drop_index(op.f("ix_celery_taskmeta_date_done"), table_name="celery_taskmeta")

0 commit comments

Comments
 (0)