summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--neutron/db/migration/alembic_migrations/versions/mitaka/expand/1df244e556f5_add_unique_ha_router_agent_port_bindings.py2
-rw-r--r--neutron/db/migration/alembic_migrations/versions/newton/expand/030a959ceafa_uniq_routerports0port_id.py2
-rw-r--r--neutron/db/migration/alembic_migrations/versions/newton/expand/6b461a21bcfc_uniq_floatingips0floating_network_.py2
-rw-r--r--neutron/db/migration/alembic_migrations/versions/wallaby/expand/f010820fc498_add_unique_quotas_project_resource.py2
4 files changed, 4 insertions, 4 deletions
diff --git a/neutron/db/migration/alembic_migrations/versions/mitaka/expand/1df244e556f5_add_unique_ha_router_agent_port_bindings.py b/neutron/db/migration/alembic_migrations/versions/mitaka/expand/1df244e556f5_add_unique_ha_router_agent_port_bindings.py
index 95596efb16..0f3310f1c2 100644
--- a/neutron/db/migration/alembic_migrations/versions/mitaka/expand/1df244e556f5_add_unique_ha_router_agent_port_bindings.py
+++ b/neutron/db/migration/alembic_migrations/versions/mitaka/expand/1df244e556f5_add_unique_ha_router_agent_port_bindings.py
@@ -63,7 +63,7 @@ def get_duplicate_l3_ha_port_bindings(connection):
insp = sa.inspect(connection)
if 'ha_router_agent_port_bindings' not in insp.get_table_names():
return {}
- session = sa.orm.Session(bind=connection.connect())
+ session = sa.orm.Session(bind=connection)
query = (session.query(ha_router_agent_port_bindings.c.router_id)
.group_by(ha_router_agent_port_bindings.c.router_id,
ha_router_agent_port_bindings.c.l3_agent_id)
diff --git a/neutron/db/migration/alembic_migrations/versions/newton/expand/030a959ceafa_uniq_routerports0port_id.py b/neutron/db/migration/alembic_migrations/versions/newton/expand/030a959ceafa_uniq_routerports0port_id.py
index 332c649854..d83aa49430 100644
--- a/neutron/db/migration/alembic_migrations/versions/newton/expand/030a959ceafa_uniq_routerports0port_id.py
+++ b/neutron/db/migration/alembic_migrations/versions/newton/expand/030a959ceafa_uniq_routerports0port_id.py
@@ -61,7 +61,7 @@ def get_duplicate_port_records_in_routerport_database(connection):
insp = sa.inspect(connection)
if 'routerports' not in insp.get_table_names():
return []
- session = sa.orm.Session(bind=connection.connect())
+ session = sa.orm.Session(bind=connection)
query = (session.query(routerports.c.port_id)
.group_by(routerports.c.port_id)
.having(sa.func.count() > 1)).all()
diff --git a/neutron/db/migration/alembic_migrations/versions/newton/expand/6b461a21bcfc_uniq_floatingips0floating_network_.py b/neutron/db/migration/alembic_migrations/versions/newton/expand/6b461a21bcfc_uniq_floatingips0floating_network_.py
index ec789b42bb..ca5e5d344a 100644
--- a/neutron/db/migration/alembic_migrations/versions/newton/expand/6b461a21bcfc_uniq_floatingips0floating_network_.py
+++ b/neutron/db/migration/alembic_migrations/versions/newton/expand/6b461a21bcfc_uniq_floatingips0floating_network_.py
@@ -63,7 +63,7 @@ def get_duplicate_floating_ip_for_one_fixed_ip(connection):
insp = sa.inspect(connection)
if 'floatingips' not in insp.get_table_names():
return []
- session = sa.orm.Session(bind=connection.connect())
+ session = sa.orm.Session(bind=connection)
query = (session.query(floatingips.c.fixed_ip_address)
.group_by(floatingips.c.floating_network_id,
floatingips.c.fixed_port_id,
diff --git a/neutron/db/migration/alembic_migrations/versions/wallaby/expand/f010820fc498_add_unique_quotas_project_resource.py b/neutron/db/migration/alembic_migrations/versions/wallaby/expand/f010820fc498_add_unique_quotas_project_resource.py
index 71af3451a6..a084a9075f 100644
--- a/neutron/db/migration/alembic_migrations/versions/wallaby/expand/f010820fc498_add_unique_quotas_project_resource.py
+++ b/neutron/db/migration/alembic_migrations/versions/wallaby/expand/f010820fc498_add_unique_quotas_project_resource.py
@@ -50,7 +50,7 @@ def get_duplicate_quotas(connection):
insp = sa.inspect(connection)
if 'quotas' not in insp.get_table_names():
return []
- session = sa.orm.Session(bind=connection.connect())
+ session = sa.orm.Session(bind=connection)
items = (session.query(quotas.c.project_id, quotas.c.resource)
.group_by(quotas.c.project_id, quotas.c.resource)
.having(sa.func.count() > 1)).all()