"""Fix user_profile task name in scheduler_configs

Revision ID: prd011_fix_user_profile_task_name
Revises: prd011_merge_scheduler_tables
Create Date: 2026-05-07 08:00:00.000000

"""
from typing import Sequence, Union
from alembic import op
from sqlalchemy import text

revision: str = "prd011_fix_task_names"
down_revision: Union[str, Sequence[str], None] = "prd011_merge_scheduler_tables"
branch_labels: Union[str, Sequence[str], None] = None
depends_on: Union[str, Sequence[str], None] = None


def upgrade() -> None:
    bind = op.get_bind()
    bind.execute(
        text(
            "UPDATE scheduler_configs "
            "SET task_name = 'user_profile.cleanup_expired_email_change_tokens' "
            "WHERE task_name = 'user-profile-cleanup-expired-email-tokens'"
        )
    )


def downgrade() -> None:
    bind = op.get_bind()
    bind.execute(
        text(
            "UPDATE scheduler_configs "
            "SET task_name = 'user-profile-cleanup-expired-email-tokens' "
            "WHERE task_name = 'user_profile.cleanup_expired_email_change_tokens'"
        )
    )