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.")