def upgrade(migrate_engine):
    meta = MetaData()
    meta.bind = migrate_engine

    # new table with desired columns, indexes, and constraints
    new_agent_heartbeats = Table(
        'agent_heartbeats', meta,
        Column('id', String(36), primary_key=True, nullable=False),
        Column('instance_id', String(36),
               nullable=False, unique=True, index=True),
        Column('guest_agent_version', String(255), index=True),
        Column('deleted', Boolean(), index=True),
        Column('deleted_at', DateTime()),
        Column('updated_at', DateTime(), nullable=False))

    # original table from migration 005_heartbeat.py
    previous_agent_heartbeats = Table('agent_heartbeats', meta, autoload=True)

    try:
        drop_tables([previous_agent_heartbeats])
    except OperationalError as e:
        logger.warn("This table may have been dropped by some other means.")
        logger.warn(e)

    create_tables([new_agent_heartbeats])

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    create_tables([configurations])
    create_tables([configuration_parameters])
    instances = Table('instances', meta, autoload=True)
    instances.create_column(Column('configuration_id', String(36),
                                   ForeignKey("configurations.id")))

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    create_tables([datastores, datastore_versions])
    instances = Table('instances', meta, autoload=True)
    datastore_version_id = Column('datastore_version_id', String(36),
                                  ForeignKey('datastore_versions.id'))
    instances.create_column(datastore_version_id)
    instances.drop_column('service_type')

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    Table(
        'instances',
        meta,
        autoload=True,
    )
    create_tables([security_groups, security_group_rules,
                   security_group_instance_associations])

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    Table('datastores', meta, autoload=True)
    Table('datastore_versions', meta, autoload=True)
    instances = Table('instances', meta, autoload=True)
    create_tables([clusters])
    instances.create_column(Column('cluster_id', String(36),
                                   ForeignKey("clusters.id")))
    instances.create_column(Column('shard_id', String(36)))
    instances.create_column(Column('type', String(64)))
    cluster_id_idx = Index("instances_cluster_id", instances.c.cluster_id)
    cluster_id_idx.create()

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    create_tables([datastores, datastore_versions])
    
#     ----------------------------------------------------
#     Fore. 2014/06/19 Not modify old schemas on Instance.
#     ----------------------------------------------------
    instances = Table('instances', meta, autoload=True)
#     datastore_version_id = Column('datastore_version_id', String(36),
#                                   ForeignKey('datastore_versions.id'))
    datastore_version_id = Column('datastore_version_id', String(36), nullable = True)
    instances.create_column(datastore_version_id)

def upgrade(migrate_engine):
    meta.bind = migrate_engine

    # for some reason we have to load the table before we can FK to it
    Table('instances', meta, autoload=True)
    create_tables([scheduled_task_types, scheduled_tasks])

    scheduled_task_types.insert().values(
        type='backup',
        enabled=True,
        description="Back up the data store for a specific instance:\n"
        "This will perform a full backup at the scheduled interval "
        "and incremental backups at a reasonable frequency in between",
    ).execute()

def upgrade(migrate_engine):
    meta.bind = migrate_engine

    # since the downgrade is a no-op, an upgrade after a downgrade will
    # cause an exception because the tables already exist
    # we will catch that case and log an info message
    try:
        create_tables([configurations])
        create_tables([configuration_parameters])

        instances = Table('instances', meta, autoload=True)
        instances.create_column(Column('configuration_id', String(36),
                                       ForeignKey("configurations.id")))
    except OperationalError as e:
        logger.info(e)

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    instance_group = Table('instance_group', meta, autoload=True)
    backups = Table('backups', meta, autoload=True)
    backups.create_column(Column('group_id', String(36)))
    backups.create_column(Column('type', String(36)))
    backups.create_column(Column('expire_at',Integer()))
    backups.create_column(Column('service_image_id',String(36)))
    
    instances = Table('instances', meta, autoload=True)
    instances.create_column(Column('group_id',String(36)))

#    drop_tables([security_group_instance_associations])    

    create_tables([InstanceGroup,InstanceGroupItem,InstanceVip,Vips,Autobackup,
                   security_group_group_associations])

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    Table('datastores', meta, autoload=True)
    Table('datastore_versions', meta, autoload=True)
    instances = Table('instances', meta, autoload=True)

    # since the downgrade is a no-op, an upgrade after a downgrade will
    # cause an exception because the tables already exist
    # we will catch that case and log an info message
    try:
        create_tables([clusters])

        instances.create_column(Column('cluster_id', String(36),
                                       ForeignKey("clusters.id")))
        instances.create_column(Column('shard_id', String(36)))
        instances.create_column(Column('type', String(64)))

        cluster_id_idx = Index("instances_cluster_id", instances.c.cluster_id)
        cluster_id_idx.create()
    except OperationalError as e:
        logger.info(e)

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    create_tables([conductor_lastseen])

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    create_tables([agent_heartbeats])

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    create_tables([root_enabled_history])

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    create_tables([private_net])

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    create_tables([quotas, quota_usages, reservations])

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    # Load the datastore_versions table into the session.
    # creates datastore_version_metadata table
    Table('datastore_versions', meta, autoload=True)
    create_tables([datastore_version_metadata])

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    Table('datastore_versions', meta, autoload=True)
    create_tables([datastore_configuration_parameters])

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    create_tables([instances])

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    create_tables([usage_events])

def upgrade(migrate_engine):
    meta.bind = migrate_engine
    Table('instances', meta, autoload=True)
    create_tables([modules, instance_modules])