Source code for heat.engine.resources.scheduler_hints

#    Licensed under the Apache License, Version 2.0 (the "License"); you may
#    not use this file except in compliance with the License. You may obtain
#    a copy of the License at
#    Unless required by applicable law or agreed to in writing, software
#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
#    License for the specific language governing permissions and limitations
#    under the License.

from oslo_config import cfg

cfg.CONF.import_opt('stack_scheduler_hints', 'heat.common.config')

[docs]class SchedulerHintsMixin(object): """Utility class to encapsulate Scheduler Hint related logic.""" HEAT_ROOT_STACK_ID = 'heat_root_stack_id' HEAT_STACK_ID = 'heat_stack_id' HEAT_STACK_NAME = 'heat_stack_name' HEAT_PATH_IN_STACK = 'heat_path_in_stack' HEAT_RESOURCE_NAME = 'heat_resource_name' HEAT_RESOURCE_UUID = 'heat_resource_uuid' @staticmethod def _path_in_stack(stack): # Note: scheduler_hints can only be of DictOfListOfStrings. # Convert the list of tuples to list of delimited strings. path = [] for parent_res_name, stack_name in stack.path_in_stack(): if parent_res_name is not None: path.append(','.join([parent_res_name, stack_name])) else: path.append(stack_name) return path def _scheduler_hints(self, scheduler_hints): """Augment scheduler hints with supplemental content.""" if cfg.CONF.stack_scheduler_hints: if scheduler_hints is None: scheduler_hints = {} stack = self.stack scheduler_hints[self.HEAT_ROOT_STACK_ID] = stack.root_stack_id() scheduler_hints[self.HEAT_STACK_ID] = scheduler_hints[self.HEAT_STACK_NAME] = scheduler_hints[ self.HEAT_PATH_IN_STACK] = self._path_in_stack(stack) scheduler_hints[self.HEAT_RESOURCE_NAME] = scheduler_hints[self.HEAT_RESOURCE_UUID] = self.uuid return scheduler_hints