"""migrade_cmf_list

Revision ID: c52ec5ea255b
Revises: 3b642a300c52
Create Date: 2020-12-24 10:44:44.556238

"""
from alembic import op
import sqlalchemy as sa
from sqlalchemy import func
import sys
from pathlib import Path
sys.path.append(str(Path(".").resolve()))
from cmf.manage import *

# revision identifiers, used by Alembic.
revision = 'c52ec5ea255b'
down_revision = '3b642a300c52'
branch_labels = None
depends_on = None


def upgrade():
    with APP.test_request_context('/'):
        s = models.CmfTask.dp.data_driver.Session()
        # UWorkList
        _fields = [models.CmfEvent.dp_model.object_id,
                   models.CmfEvent.dp_model.view_object_id]
        for field in _fields:
            s.query_deprecated(field).filter(field.like('CmfUWorkList%')).update(
                {field: func.replace(field, 'CmfUWorkList', 'CmfList')},
                synchronize_session=False)


def downgrade():
    pass