summaryrefslogtreecommitdiff
path: root/heat/cmd/manage.py
diff options
context:
space:
mode:
authorThomas Herve <therve@redhat.com>2016-10-19 15:59:28 +0200
committerThomas Herve <therve@redhat.com>2016-12-13 09:40:29 +0100
commit84067dba88a64eab87369abc40566b6af3b49d66 (patch)
treeb3daa9727cb915f07e84fc716185541397cc86b7 /heat/cmd/manage.py
parent1190b1bead74761e2e45a265fbdda51148ce806a (diff)
downloadheat-84067dba88a64eab87369abc40566b6af3b49d66.tar.gz
Remove db.api wrapper
The db.api module provides a useless indirection to the only implementation we ever had, sqlalchemy. Let's use that directly instead of the wrapper. Change-Id: I80353cfed801b95571523515fd3228eae45c96ae
Diffstat (limited to 'heat/cmd/manage.py')
-rw-r--r--heat/cmd/manage.py15
1 files changed, 7 insertions, 8 deletions
diff --git a/heat/cmd/manage.py b/heat/cmd/manage.py
index 6f1b6e1f5..7d1465deb 100644
--- a/heat/cmd/manage.py
+++ b/heat/cmd/manage.py
@@ -26,8 +26,7 @@ from heat.common import exception
from heat.common.i18n import _
from heat.common import messaging
from heat.common import service_utils
-from heat.db import api as db_api
-from heat.db import utils
+from heat.db.sqlalchemy import api as db_api
from heat.objects import service as service_objects
from heat.rpc import client as rpc_client
from heat import version
@@ -131,10 +130,10 @@ def do_migrate():
def purge_deleted():
"""Remove database records that have been previously soft deleted."""
- utils.purge_deleted(CONF.command.age,
- CONF.command.granularity,
- CONF.command.project_id,
- CONF.command.batch_size)
+ db_api.purge_deleted(CONF.command.age,
+ CONF.command.granularity,
+ CONF.command.project_id,
+ CONF.command.batch_size)
def do_crypt_parameters_and_properties():
@@ -142,10 +141,10 @@ def do_crypt_parameters_and_properties():
ctxt = context.get_admin_context()
prev_encryption_key = CONF.command.previous_encryption_key
if CONF.command.crypt_operation == "encrypt":
- utils.encrypt_parameters_and_properties(
+ db_api.encrypt_parameters_and_properties(
ctxt, prev_encryption_key, CONF.command.verbose_update_params)
elif CONF.command.crypt_operation == "decrypt":
- utils.decrypt_parameters_and_properties(
+ db_api.decrypt_parameters_and_properties(
ctxt, prev_encryption_key, CONF.command.verbose_update_params)