+?`dZddlmZddlmZddlmZddlZddlmZddl m Z ddl m Z dd l m Z ddl mZdd l mZdd l mZdd lmZdd lmZddlmZddlZddlmZGddej.ZGddej.ZGddeZdZdZdZdZdZ dZ!dZ"dZ#dZ$y)z-Utilities for dealing with version resources.)absolute_import)division)unicode_literalsN) exceptions)env) metric_names)operations_util)log)metrics)retry)text)times)mapc eZdZy)VersionValidationErrorN__name__ __module__ __qualname__.lib/googlecloudsdk/api_lib/app/version_util.pyrr&rrc eZdZy)VersionsDeleteErrorNrrrrrr*rrrcreZdZdZdZdZdZ ddZedZ edZ d Z d Z d Z d Zd ZdZy)VersionzValue class representing a version resource. This wrapper around appengine__messages.Version is necessary because Versions don't have traffic split, project, or last_deployed_time as a datetime object. g-C6?zFapps/(?P.*)/services/(?P.*)/versions/(?P.*)Nc t||_||_||_||_||_||_||_||_yN)projectserviceidversion traffic_splitlast_deployed_time environmentservice_account) selfr!r" version_idr%r&r'version_resourcer(s r__init__zVersion.__init__Bs@DLDLDG#DL&D0D"D*Drc|jd}dt|cxkr|jkstdtddg|jt|z z|z}||S)N/rzJ[{0}] is not a valid resource path. Expected //)splitlen_RESOURCE_PATH_PARTSr)clspathpartss rFromResourcePathzVersion.FromResourcePathTs JJsOE s5z 5S55 5 "$L MM 6 "$L MMFc..U; _messages.Version into wrapped Version.gNr) microsecondflexible)r%r&r'r+)rematch_VERSION_NAME_PATTERNnamegroupsr/getr# createTimer ParseDateTimereplaceLocalizeDateTime ValueErrorrFLEXvm MANAGED_VMSSTANDARD) r2r$r"r! service_id_r% last_deployedlast_deployed_dtr's rFromVersionResourcezVersion.FromVersionResource^s XXc&?&?&-ll44:FHGZB 1 1'**c BMM    ..w/A/ABJJK../?@ {{j HHk OOkLLk w GJJm"/[ ' ))    s*AD D,+D,cLt|jdz |jkS)Ng?)absr%_ALL_TRAFFIC_EPSILONr)s rIsReceivingAllTrafficzVersion.IsReceivingAllTrafficvs# t!!C' (4+D+D DDrc |jsh |j|j|j|_|js$t j dj ||jS|jS#tj$r`}t jdj tj|tj|Yd}~|jSd}~wwxYw)aGAttempts to load the Version resource for this version. Returns the cached Version resource if it exists. Otherwise, attempts to load it from the server. Errors are logged and ignored. Args: api_client: An AppengineApiClient. Returns: The Version resource, or None if it could not be loaded. z-Failed to retrieve resource for version [{0}]z,Error retrieving Version resource [{0}]: {1}N) r$GetVersionResourcer"r#r infoformatapitools_exceptionsErrorwarningsix text_type)r) api_clientes rrSzVersion.GetVersionResourceys << D!44T\\477K || ((BII$O P <<4<< ! & &D BVCMM$/q1AB D D << DsABC4A C//C4ct|tuxrO|j|jk(xr4|j|jk(xr|j|jk(Sr )typerr!r"r#r)others r__eq__zVersion.__eq__sT K7 " LLEMM ) LLEMM )  GGuxx !rc||k( Sr rr_s r__ne__zVersion.__ne__su} rct|j|j|jf|j|j|jfSr )cmpr!r"r#r_s r__cmp__zVersion.__cmp__s:  dllDGG4 u}}ehh7 99rcddj|j|j|jS)Nz {0}/{1}/{2})rUr!r"r#rPs r__str__zVersion.__str__s#    dllDGG DDr)NNNNN)rrr__doc__rOr1r;r, classmethodr5rLrQrSrarcrfrhrrrrr.s{6""& $#+$)).E2! 9Errc|D]}|j|Dcgc]}|jc}vr$tdj|j||vsRtdj|j|jycc}w)aXValidate that each version in filtered_versions is also in all_versions. Args: filtered_versions: list of Version representing a filtered subset of all_versions. all_versions: list of Version representing all versions in the current project. Raises: VersionValidationError: If a service or version is not found. Service [{0}] not found.zVersion [{0}/{1}] not found.Nr"rrUr#)filtered_versions all_versionsr$vs r_ValidateServicesAreSubsetrqs#g,?,Qqyy,?? " $ + +GOO < >>l" " ( / /07  < == #?sBctttj|}|D]R}|js|j s t d|jr|j|k7r t d||_T|S)aEParse the list of resource paths specifying versions. Args: paths: The list of resource paths by which to filter. project: The current project. Used for validation. Returns: list of Version Raises: VersionValidationError: If not all versions are valid resource paths for the current project. zTIf you provide a resource path as an argument, all arguments must be resource paths.z,All versions must be in the current project.)listrrr5r!r"r)pathsr!versionsr$s rParseVersionResourcePathsrvsv#g..6 7(g OOw "$, --7??g5 " 8 ::GO /rc|}|rU||Dcgc]}|jc}vrtdj||Dcgc]}|j|k(s|}}|r|Dcgc]}|j|vs|}}|Scc}wcc}wcc}w)aReturn a list of versions to act on based on user arguments. Args: all_versions: list of Version representing all services in the project. versions: list of string, version names to filter for. If empty, match all versions. service: string or None, service name. If given, only match versions in the given service. Returns: list of matching Version Raises: VersionValidationError: If an improper combination of arguments is given. rlrm)rorur"rnrps rGetMatchingVersionsrxs # ,7,Qqyy,77 "#=#D#DW#M NN$0ILqAII4HLI $5J$5q9I$5J 8IKsA<BB B4Bc i}|D]^}dj|j|j} tj|j |j|j`|ri}|jD]\}}dj||||<tdjtjt|ddjt|j!djt|j#zy#tj $r#}tj|||<Yd}~Kd}~wwxYw)z/Delete the given version of the given services.z{0}/{1}Nz [{0}]: {1}zIssue deleting {0}: [{1}] r$z, z )rUr"r#r CallAndCollectOpErrors DeleteVersionMiscOperationErrorrYrZitemsrr Pluralizer0joinrskeysvalues)r[ruerrorsr$ version_patherrprintable_errors error_msgs rDeleteVersionsrs. &g##GOOWZZ@L0,,  " "GOOWZZA #)<<> i'3':':<;D(F|$$2 '.. NN3/0) < IId+0023 4 6  D)00234 5 66    - -0 ]]3/f\0s5DE2EEcd}|r t|||}|j|}|jjj}|ro|j |j k(rVtjjdj||j|j|jdt|||rt|||yy)aPromote the new version to receive all traffic. First starts the new version if it is not running. Additionally, stops the previous version if stop_previous_version is True and it is possible to stop the previous version. Args: all_services: {str, Service}, A mapping of service id to Service objects for all services in the app. new_version: Version, The version to promote. api_client: appengine_api_client.AppengineApiClient to use to make requests. stop_previous_version: bool, True to stop the previous version which was receiving all traffic, if any. wait_for_stop_version: bool, indicating whether to wait for stop operation to finish. Nz+Starting version [{0}] before promoting it.T)block)_GetPreviousVersionrSmessagesrServingStatusValueValuesEnum servingStatusSTOPPEDr statusPrintrU StartVersionr"r#_SetDefaultVersion_StopPreviousVersionIfApplies) all_services new_versionr[stop_previous_versionwait_for_stop_versionold_default_versionnew_version_resource status_enums rPromoteVersionrs&.k:/%77 C##++HH+((K,?,??JJBf[)+K//tL[*-!"5z"79rc.|jjSr )r$ versionUrl)r$s rGetUrir3s  # ##rc|j|jd}|sy|j|gD]0}|js|j|jk7s.|cSy)aGet the previous default version of which new_version is replacing. If there is no such version, return None. Args: all_services: {str, Service}, A mapping of service id to Service objects for all services in the app. new_version: Version, The version to promote. api_client: appengine_api_client.AppengineApiClient, The client for talking to the App Engine Admin API. Returns: Version, The previous version or None. N)r>r" ListVersionsrQr#)rrr[r" old_versions rrr7s]   [00$ 7'  ,,gY7k ))++..(  8rctjtjd} t j dd}|j |j|j|jg|dtjtjy #tj$rM}|j\}}|rtj|d|dntjYd }~d }~wwxYw) zSets the given version as the default. Args: new_version: Version, The version to promote. api_client: appengine_api_client.AppengineApiClient to use to make requests. c6t|tjSr ) issubclassrV HttpError)exc_typeunused_exc_valueunused_traceback unused_states r ShouldRetryz'_SetDefaultVersion..ShouldRetry[s h 3 = = >>rr) max_retrialsexponential_sleep_multiplieri)should_retry_ifsleep_ms)tbN)r CustomTimedEventrSET_DEFAULT_VERSION_API_STARTr RetryerRetryOnExceptionSetDefaultVersionr"r#MaxRetrialsException last_resultrreraise InternalErrorSET_DEFAULT_VERSION_API)rr[rretryerr\ unused_resultexc_infos rrrRs <EEF? 'mmKG $${':':KNN&K#d4 <??@  # #' ! ]H!!5  $ $ && 6'sA BC8+AC33C8c |j}|jjj}|j|j k7r%t jdj|y|jxs |jdk(xs|jdk( }|r=|js1|js%t jdj|yt jjdj| tj |j"|j$|j&||s/t jjdj|yy#tj($rf}t j*d j|t-j.|t j*d j|Yd}~yd}~wwxYw) a!Stop the previous default version if applicable. Cases where a version will not be stopped: * If the previous default version is not serving, there is no need to stop it. * If the previous default version is an automatically scaled standard environment app, it cannot be stopped. Args: old_default_version: Version, The old default version to stop. api_client: appengine_api_client.AppengineApiClient to use to make requests. wait_for_stop_version: bool, indicating whether to wait for stop operation to finish. z?Previous default version [{0}] not serving, so not stopping it.Nflexr8zgPrevious default version [{0}] is an automatically scaled standard environment app, so not stopping it.zStopping version [{0}].) service_namer*rzSent request to stop version [{0}]. This operation may take some time to complete. If you would like to verify that it succeeded, run: $ gcloud app versions describe -s {0.service} {0.id} until it shows that the version has stopped.z!Error stopping version [{0}]: {1}zVersion [{0}] is still running and you must stop or delete it yourself in order to turn it off. (If you do not, you may be charged.))r$rrrrSERVINGr rTrUrEr basicScaling manualScalingrrr rz StopVersionr"r#r|rXrYrZ)rr[rversion_objectr is_standardrs rrrns '...##++HH+!![%8%88HH f()+ #&&6.*<*<*F6#'':57+.55  & &HH 88> 9!" **,334GHI$ **(00&))# % ! jj 9:@!:# $ !  + +9KK3::;N;>==;MOPKK"F#67999s7E11G*AG%%G*)%ri __future__rrrr9apitools.base.pyrrVgooglecloudsdk.api_lib.apprrr googlecloudsdk.corer r googlecloudsdk.core.utilr r rrY six.movesrrWrrobjectrrqrvrxrrrrrrrrrrs 4&' >*36*#'*)* Z--***rEfrEj=,886.(9V$6A8<$r