summaryrefslogtreecommitdiffstats
path: root/bin
diff options
context:
space:
mode:
authorJenkins <jenkins@review.openstack.org>2012-05-31 01:29:40 +0000
committerGerrit Code Review <review@openstack.org>2012-05-31 01:29:40 +0000
commitf3edf7ff7edefede242de50aca59abc4c6adc7f9 (patch)
tree68e8260744e8ae02515c02fe71251362a031506f /bin
parent069f8f3ea4ac20271cddca0c3e209ef0af8cd0d6 (diff)
parent26353bb372081f674cf5fd3dbbffd990918f3803 (diff)
Merge "Move queue_get_for() from db to rpc."
Diffstat (limited to 'bin')
-rwxr-xr-xbin/nova-manage4
1 files changed, 2 insertions, 2 deletions
diff --git a/bin/nova-manage b/bin/nova-manage
index 20326b3c4..1554251a0 100755
--- a/bin/nova-manage
+++ b/bin/nova-manage
@@ -1153,7 +1153,7 @@ class VolumeCommands(object):
return
rpc.cast(ctxt,
- db.queue_get_for(ctxt, FLAGS.volume_topic, host),
+ rpc.queue_get_for(ctxt, FLAGS.volume_topic, host),
{"method": "delete_volume",
"args": {"volume_id": volume['id']}})
@@ -1171,7 +1171,7 @@ class VolumeCommands(object):
instance = db.instance_get(ctxt, volume['instance_id'])
host = instance['host']
rpc.cast(ctxt,
- db.queue_get_for(ctxt, FLAGS.compute_topic, host),
+ rpc.queue_get_for(ctxt, FLAGS.compute_topic, host),
{"method": "attach_volume",
"args": {"instance_id": instance['id'],
"volume_id": volume['id'],