# Generated by Django 3.2.20 on 2023-11-03 00:20
|
|
from django.db import migrations
|
from projects.models import Project
|
from core.models import AsyncMigrationStatus
|
from core.redis import start_job_async_or_sync
|
import logging
|
|
|
logger = logging.getLogger(__name__)
|
|
|
def _fill_label_config_hash(migration_name, db_alias):
|
project_tuples = Project.objects.using(db_alias).all().values_list('id', 'parsed_label_config')
|
for project_id, parsed_label_config in project_tuples:
|
migration = AsyncMigrationStatus.objects.using(db_alias).create(
|
project_id=project_id,
|
name=migration_name,
|
status=AsyncMigrationStatus.STATUS_STARTED,
|
)
|
|
hashed_label_config = hash(str(parsed_label_config))
|
Project.objects.using(db_alias).filter(id=project_id).update(label_config_hash=hashed_label_config)
|
|
migration.status = AsyncMigrationStatus.STATUS_FINISHED
|
migration.save(using=db_alias)
|
|
|
def fill_label_config_hash(migration_name, db_alias):
|
logger.info('Start filling label config hash')
|
start_job_async_or_sync(_fill_label_config_hash, migration_name=migration_name, db_alias=db_alias)
|
logger.info('Finished filling label config hash')
|
|
|
def forward(apps, schema_editor):
|
db_alias = schema_editor.connection.alias
|
fill_label_config_hash('0026_auto_20231103_0020', db_alias)
|
|
|
def backwards(apps, schema_editor):
|
pass
|
|
|
class Migration(migrations.Migration):
|
|
dependencies = [
|
('projects', '0025_project_label_config_hash'),
|
]
|
|
operations = [
|
migrations.RunPython(forward, backwards)
|
]
|
