Warning

This document is for an old release of Galaxy. You can alternatively view this page in the latest release if it exists or view the top of the latest release's documentation.

Source code for galaxy.model.migrate.versions.0140_add_dataset_version_to_job_to_input_dataset_association_table

"""
Add dataset_version column to job_to_input_dataset table
"""

import logging

from sqlalchemy import Column, Integer, MetaData, Table

log = logging.getLogger(__name__)
dataset_version_column = Column("dataset_version", Integer)


[docs]def upgrade(migrate_engine): print(__doc__) metadata = MetaData() metadata.bind = migrate_engine metadata.reflect() # Add the version column to the job_to_input_dataset table try: job_to_input_dataset_table = Table("job_to_input_dataset", metadata, autoload=True) dataset_version_column.create(job_to_input_dataset_table) assert dataset_version_column is job_to_input_dataset_table.c.dataset_version except Exception: log.exception("Adding column 'dataset_history_id' to job_to_input_dataset table failed.")
[docs]def downgrade(migrate_engine): metadata = MetaData() metadata.bind = migrate_engine metadata.reflect() # Drop the job_to_input_dataset table's version column. try: job_to_input_dataset_table = Table("job_to_input_dataset", metadata, autoload=True) dataset_version_column = job_to_input_dataset_table.c.dataset_version dataset_version_column.drop() except Exception: log.exception("Dropping 'dataset_version' column from job_to_input_dataset table failed.")