Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
triliodata-3-4 / contego deb
Repository URL to install this package:
|
Version:
3.4.36 ▾
|
ó
±EYc @ sÚ d Z d d l Z d d l Z d d l Z d d l m Z d d l Z d d l m
Z
d d l m Z d d l m
Z d d l Z d d l m Z d d l m Z m Z m Z d d l m Z d d
l m Z d d l m Z d d l m Z e j e Z e j j! Z! e j" d
d d d g Z# d d Z% d Z& d Z' d Z( d Z) d Z* d Z+ d e, d d Z- d Z. d Z/ d a0 d a1 d a2 d a3 d d Z4 d Z5 d d Z6 e6 e! j7 d Z8 d S(! s Utility methods for scheduling.iÿÿÿÿN( t log( t jsonutils( t flavors( t utils( t exception( t _t _LEt _LW( t objects( t base( t instance( t rpct GroupDetailst hostst policiest membersc C s | d } | d k rI t | t j r7 | j } qI t j | } n t | t j r t j | } t | j
d i | d <n t | t j rá t j | } y t j
| j
d i | Wqá t k
rÝ qá Xn i | pí i d 6| d 6| d 6t | d 6} t j | S( s Build a request_spec for the scheduler.
The request_spec assumes that all instances to be scheduled are the same
type.
i t system_metadatat imaget instance_propertiest
instance_typet
num_instancesN( t Nonet
isinstancet obj_instancet Instancet
get_flavorR t extract_flavort obj_baset obj_to_primitivet dictt getR t Flavort save_flavor_infot KeyErrort lenR t to_primitive( t ctxtR t instancesR R
t request_spec( ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt build_request_spec, s*
c
C s# t j t d i | d 6| d 6| d 6 | d } | j d i } t j | } | j }
t j t d |
d | t j d | d
| | } | j d
g | j
t j | | | t
j t d | d | d | d
| d | d | } d | | f }
| j | |
| d S( s changes VM state and notifies.s( Failed to %(service)s_%(method)s: %(ex)st servicet methodt ext vm_stateR s Setting instance to %s state.t
instance_uuidt contextt uuidR& t instance_idt statet reasons %s.%sN( t LOGt warningR R R t get_notifiert upperR R t obj_reset_changest savet
compute_utilst add_instance_fault_from_exct syst exc_infoR t error( R- R, R( R) t updatesR* R& R+ t
propertiest notifierR0 R
t payloadt
event_type( ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt set_vm_state_and_notifyU s,
c C sI t d | } | | d <| r/ | g | d <n | rE | g | d <n | S( s? Build the filter_properties dict from data in the boot request.t scheduler_hintsR t force_hostst force_nodes( R ( RC t forced_hostt forced_nodeR t filter_properties( ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt build_filter_propertiesv s
c C s{ t | t r0 | d } | d } | d } n | j } | j } | j } t | | | | j d sw | | d <n d S( sv Add additional information to the filter properties after a node has
been selected by the scheduling process.
t hostt nodenamet limitsRD N( R R RJ RK RL t _add_retry_hostR ( RH t
host_stateRJ RK RL ( ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt populate_filter_properties s
c C sþ t j } | j d g } | j d g } | d k s] t | d k s] t | d k ra d S| j d i d d 6g d 6 } | d c d 7<t | | | j d d } | d | k rú t d i | d
6| d 6| d 6} t j
d | n d S(
NRD RE i t retryi t num_attemptsR
t
exc_reasonsp Exceeded max scheduling attempts %(max_attempts)d for instance %(instance_uuid)s. Last exception: %(exc_reason)st max_attemptsR, R1 ( t CONFt scheduler_max_attemptsR R" t
setdefaultt _log_compute_errort popR R R t MaxRetriesExceeded( RH R, RS RD RE RP RR t msg( ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt populate_retry s&
c C sz | j d } | s d S| j d d } | s5 d S| d \ } } t j t d i | d 6| d 6| d 6d | d S( sv If the request contained an exception from a previous compute
build/resize operation, log it to aid debugging
t excNR
iÿÿÿÿsA Error from last host: %(last_host)s (node %(last_node)s): %(exc)st last_hostt last_nodeR, ( R R R2 R< R ( R, RP R\ R
R] R^ ( ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyRW » s
c C s= | j d d } | s d S| d } | j | | g d S( s± Add a retry entry for the selected compute node. In the event that
the request gets re-scheduled, this entry will signal that the given
node has already been tried.
RP NR
( R R t append( RH RJ t nodeRP R
( ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyRM Ð s
t =t c
C sÚ g } g } x | D] } y( | j | \ } } } | | } Wn t k
r` d } d } n X| r | r | d k r | j | | f q | j | q W| rÖ t j t d i | d 6d j | d 6 n | S( s× Parse a list of options, each in the format of <key><sep><value>. Also
use the converter to convert the value into desired type.
:params opts: list of options, e.g. from oslo_config.cfg.ListOpt
:params sep: the separator
:params converter: callable object to convert the value, should raise
ValueError for conversion failure
:params name: name of the option
:returns: a lists of tuple of values (key, converted_value)
sA Ignoring the invalid elements of the option %(name)s: %(options)st names , t optionsN( t partitiont
ValueErrorR R_ R2 R3 R t join(
t optst sept converterRc t goodt badt optt keyt seen_sept value( ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt
parse_optionsÜ s"
c C s
| t j k S( s? Validates that the filter is configured in the default filters.( RT t scheduler_default_filters( t filter( ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt validate_filterý s c C s d t j k r t S| t j k S( sA Validates that the weigher is configured in the default weighers.s# nova.scheduler.weights.all_weighers( RT t scheduler_weight_classest True( t weigher( ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt validate_weigher s c s6 t d k r t d a n t d k r6 t d a n t d k rQ t d a n t d k rl t d a n | sv d Sy t j j | | } Wn t
j k
r¦ d SXt d t
f d
| j D r2t rd | j k rt d } t j | t
j d | n t rZd | j k rZt d
} t j | t
j d | n t rd | j k rt d } t j | t
j d | n t râd | j k rât d } t j | t
j d | n t | j } | rt | n t } t d | | Bd | j d | j Sd S( sJ Provide group_hosts and group_policies sets related to instances if
those instances are belonging to a group and if corresponding filters are
enabled.
:param instance_uuid: UUID of the instance to check
:param user_group_hosts: Hosts from the group or empty set
:returns: None or namedtuple GroupDetails
t ServerGroupAffinityFiltert ServerGroupAntiAffinityFilters> nova.scheduler.weights.affinity.ServerGroupSoftAffinityWeighersB nova.scheduler.weights.affinity.ServerGroupSoftAntiAffinityWeigherNs
anti-affinityt affinitys
soft-affinitys soft-anti-affinityc 3 s | ] } | k Vq d S( N( ( t .0t policy( R ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pys <genexpr>6 s s( ServerGroupAffinityFilter not configuredR1 s, ServerGroupAntiAffinityFilter not configureds- ServerGroupSoftAffinityWeigher not configureds1 ServerGroupSoftAntiAffinityWeigher not configuredR
R R ( s
anti-affinityR{ s
soft-affinitys soft-anti-affinity( t _SUPPORTS_AFFINITYR Rt t _SUPPORTS_ANTI_AFFINITYt _SUPPORTS_SOFT_AFFINITYRx t _SUPPORTS_SOFT_ANTI_AFFINITYR t
InstanceGroupt get_by_instance_uuidR t InstanceGroupNotFoundt sett anyR R R2 R< t UnsupportedPolicyExceptiont get_hostsR R ( R- R, t user_group_hostst groupRZ t group_hostst
user_hosts( ( R sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt _get_group_details sX
c C s | j d } | j d i j d } t | | | } | d k r| t | d <| j | d <| j | d <| j | d <n d S( s Add group_hosts and group_policies fields to filter_properties dict
based on instance uuids provided in request_spec, if those instances are
belonging to a group.
:param request_spec: Request spec
:param filter_properties: Filter properties
R R R. t
group_updatedt group_policiest
group_membersN( R R R Rv R
R R ( R- R& RH R R, t
group_info( ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt setup_instance_groupO s
i c s f d } | S( s½ Retry the call in case a MessagingTimeout is raised.
A decorator for retrying calls when a service dies mid-request.
:param retries: Number of retries
:returns: Decorator
c s% t j f d } | S( Nc s d } x| t r y | | SWq t j k
r | d 7} | k rz t j t d i | d 6 d 6 j d 6 q q Xq Wd S( Ni i sO Retrying %(name)s after a MessagingTimeout, attempt %(attempt)s of %(retries)s.t attemptt retriesRc ( Rv t messagingt MessagingTimeoutR2 R3 R t __name__( t argst kwargsR ( t funcR ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt wrappedm s
( t functoolst wraps( R R ( R ( R sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt outerl s !( ( R R ( ( R sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt retry_on_timeoutd s (9 t __doc__t collectionsR R: t oslo_logR t loggingt oslo_messagingR t oslo_serializationR t nova.computeR R R8 t nova.conft novaR t nova.i18nR R R R t nova.objectsR R R
R R t getLoggerR R2 t confRT t
namedtupleR R R' RB RI RO R[ RW RM t strRq Rt Rx R~ R R R R R R RU t retry_select_destinations( ( ( sI /home/tvault/.virtenv/lib/python2.7/site-packages/nova/scheduler/utils.pyt <module> sJ ) ! " ! @