Source code for aiida.backends.djsite.db.migrations.0026_trajectory_symbols_to_attribute

# -*- coding: utf-8 -*-
###########################################################################
# Copyright (c), The AiiDA team. All rights reserved.                     #
# This file is part of the AiiDA code.                                    #
#                                                                         #
# The code is hosted on GitHub at https://github.com/aiidateam/aiida-core #
# For further information on the license, see the LICENSE.txt file        #
# For further information please visit http://www.aiida.net               #
###########################################################################
# pylint: disable=invalid-name
"""Data migration for `TrajectoryData` nodes where symbol lists are moved from repository array to attribute.

This process has to be done in two separate consecutive migrations to prevent data loss in between.
"""

# Remove when https://github.com/PyCQA/pylint/issues/1931 is fixed
# pylint: disable=no-member,no-name-in-module,import-error
from django.db import migrations

from aiida.backends.djsite.db.migrations import upgrade_schema_version
from aiida.backends.general.migrations.utils import load_numpy_array_from_repository
from . import ModelModifierV0025

REVISION = '1.0.26'
DOWN_REVISION = '1.0.25'


[docs]def create_trajectory_symbols_attribute(apps, _): """Create the symbols attribute from the repository array for all `TrajectoryData` nodes.""" DbNode = apps.get_model('db', 'DbNode') DbAttribute = apps.get_model('db', 'DbAttribute') modifier = ModelModifierV0025(apps, DbAttribute) nodes = DbNode.objects.filter(type='node.data.array.trajectory.TrajectoryData.').values_list('id', 'uuid') for pk, uuid in nodes: symbols = load_numpy_array_from_repository(uuid, 'symbols').tolist() modifier.set_value_for_node(DbNode.objects.get(pk=pk), 'symbols', symbols)
[docs]def delete_trajectory_symbols_attribute(apps, _): """Delete the symbols attribute for all `TrajectoryData` nodes.""" DbNode = apps.get_model('db', 'DbNode') DbAttribute = apps.get_model('db', 'DbAttribute') modifier = ModelModifierV0025(apps, DbAttribute) nodes = DbNode.objects.filter(type='node.data.array.trajectory.TrajectoryData.').values_list('id', flat=True) for pk in nodes: modifier.del_value_for_node(DbNode.objects.get(pk=pk), 'symbols')
[docs]class Migration(migrations.Migration): """Storing symbols in TrajectoryData nodes as attributes, while keeping numpy arrays. TrajectoryData symbols arrays are deleted in the next migration. We split the migration into two because every migration is wrapped in an atomic transaction and we want to avoid to delete the data while it is written in the database""" dependencies = [ ('db', '0025_move_data_within_node_module'), ] operations = [ migrations.RunPython(create_trajectory_symbols_attribute, reverse_code=delete_trajectory_symbols_attribute), upgrade_schema_version(REVISION, DOWN_REVISION) ]