diff --git a/nova/scheduler/multi.py b/nova/scheduler/multi.py index 3bec060a..d29370ff 100644 --- a/nova/scheduler/multi.py +++ b/nova/scheduler/multi.py @@ -41,10 +41,8 @@ FLAGS = flags.FLAGS FLAGS.register_opts(multi_scheduler_opts) # A mapping of methods to topics so we can figure out which driver to use. -_METHOD_MAP = {'run_instance': 'compute', - 'prep_resize': 'compute', - 'live_migration': 'compute', - 'create_volume': 'volume', +# There are currently no compute methods proxied through the map +_METHOD_MAP = {'create_volume': 'volume', 'create_volumes': 'volume'} @@ -75,3 +73,9 @@ class MultiScheduler(driver.Scheduler): def schedule(self, context, topic, method, *_args, **_kwargs): return self.drivers[topic].schedule(context, topic, method, *_args, **_kwargs) + + def schedule_run_instance(self, *args, **kwargs): + return self.drivers['compute'].schedule_run_instance(*args, **kwargs) + + def schedule_prep_resize(self, *args, **kwargs): + return self.drivers['compute'].schedule_prep_resize(*args, **kwargs) diff --git a/nova/tests/scheduler/test_multi_scheduler.py b/nova/tests/scheduler/test_multi_scheduler.py index 7468a244..3d7220c2 100644 --- a/nova/tests/scheduler/test_multi_scheduler.py +++ b/nova/tests/scheduler/test_multi_scheduler.py @@ -28,13 +28,7 @@ from nova.tests.scheduler import test_scheduler class FakeComputeScheduler(driver.Scheduler): is_fake_compute = True - def schedule_run_instance(self, *args, **kwargs): - pass - - def schedule_live_migration(self, *args, **kwargs): - pass - - def schedule_prep_resize(self, *args, **kwargs): + def schedule_theoretical(self, *args, **kwargs): pass def schedule(self, *args, **kwargs): @@ -79,7 +73,8 @@ class MultiDriverTestCase(test_scheduler.SchedulerTestCase): compute_driver = mgr.drivers['compute'] volume_driver = mgr.drivers['volume'] - test_methods = {compute_driver: ['run_instance', 'prep_resize'], + #no compute methods are proxied at this time + test_methods = {compute_driver: [], volume_driver: ['create_volume', 'create_volumes']} for driver, methods in test_methods.iteritems():