+?`SrSSKJr SSKJr SSKJr SSKrSSKJr SSK J r SSK J r SS K J r SSK Jr SS K Jr SS K Jr SS KJr SS KJr SSKJr SSKrSSKJr "SS\R.5r"SS\R.5r"SS\5rSrSrSrSrSr Sr!Sr"Sr#Sr$g)z-Utilities for dealing with version resources.)absolute_import)division)unicode_literalsN) exceptions)env) metric_names)operations_util)log)metrics)retry)text)times)mapc\rSrSrSrg)VersionValidationError&N__name__ __module__ __qualname____firstlineno____static_attributes__r.lib/googlecloudsdk/api_lib/app/version_util.pyrr&rrc\rSrSrSrg)VersionsDeleteError*rNrrrrrr*rrrc|\rSrSrSrSrSrSrSSjr\ S5r \ S 5r S r S r S rS rSrSrSrg)Version.zValue 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 dXlX lX0lXplX@lXPlX`lXlgN)projectserviceidversion traffic_splitlast_deployed_time environmentservice_account) selfr&r' version_idr*r+r,version_resourcer-s r__init__Version.__init__Bs0LLG#L&0"*rcURS5nS[U5s=:aUR::d O [S5eS/UR[U5- -U-nU"U6$)N/rzJ[{0}] is not a valid resource path. Expected //)splitlen_RESOURCE_PATH_PARTSr)clspathpartss rFromResourcePathVersion.FromResourcePathTsg JJsOE s5z 5S55 5 "$L MMFc..U; _messages.Version into wrapped Version.gNr) microsecondflexible)r*r+r,r0)rematch_VERSION_NAME_PATTERNnamegroupsr5getr( createTimer ParseDateTimereplaceLocalizeDateTime ValueErrorrFLEXvm MANAGED_VMSSTANDARD) r8r)r'r& service_id_r* last_deployedlast_deployed_dtr,s rFromVersionResourceVersion.FromVersionResource^s XXc&?&?&-ll44:FHGB 1 1'**c BMM    ..w/A/ABJJK../?@ {{j HHk OOkLLk wGJJm"/ ' ))    s/AD** D76D7cL[URS- 5UR:$)Ng?)absr*_ALL_TRAFFIC_EPSILONr.s rIsReceivingAllTrafficVersion.IsReceivingAllTrafficvs# t!!C' (4+D+D DDrc  UR(dnURURUR5UlUR(d%[R "SR U55 UR$UR$![Racn[R"SR [R"U5[R"U555 SnAUR$SnAff=f)a+Attempts 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 rr\Version.GetVersionResourceys << D!44T\\477K || ((BII$O P <<4<< ! & &D BVCMM$/q1AB D D << DsA!B D AC>>Dc[U5[L=(aY URUR:H=(a9 URUR:H=(a URUR:H$r%)typer!r&r'r(r.others r__eq__Version.__eq__sT K7 " LLEMM ) LLEMM )  GGuxx !rc X:X+$r%rris r__ne__Version.__ne__s  rc[URURUR4URURUR45$r%)cmpr&r'r(ris r__cmp__Version.__cmp__s:  dllDGG4 u}}ehh7 99rcdSRURURUR5$)Nz {0}/{1}/{2})r^r&r'r(rXs r__str__Version.__str__s#    dllDGG DDr)r,r(r+r&r'r-r*r))NNNNN)rrrr__doc__rWr7rBr1 classmethodr;rSrYr\rkrnrrrurrrrr!r!.s{6""& $#+$)).E2! 9Err!c$UHnURUVs/sHo3RPM sn;a$[SRUR55eX!;dMX[SRURUR55e gs snf)aHValidate 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'rr^r()filtered_versions all_versionsr)vs r_ValidateServicesAreSubsetrs{#g,?,Qyy,?? " $ + +GOO < >>" " ( / /07  < == #?sB c[[[RU55nUHbnUR(dUR (d [ S5eUR(aURU:wa [ S5eXlMd U$)a3Parse 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.)listrr!r;r&r'r)pathsr&versionsr)s rParseVersionResourcePathsrst#g..6 7(g OOw "$, --7??g5 " 8 ::O /rcBUnU(a\X Vs/sHoDRPM sn;a[SRU55eUVs/sHoDRU:XdMUPM nnU(a#UVs/sHoDRU;dMUPM nnU$s snfs snfs snf)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. rzr{)r}rr'r|r~s rGetMatchingVersionsrs # ,7,Qyy,77 "#=#D#DW#M NN$0ILqII4HLI $5J$5q9I$5J 8IKsBBB1BBc 0nUH`nSRURUR5n[R"UR URUR5 Mb U(a0nUR5HupGSRUU5Xd'M [SR[R"[U5S5SR[UR!5555SR[UR#555-5eg![R a$n[R"U5X$'SnAGMVSnAff=f)z/Delete the given version of the given services.z{0}/{1}Nz [{0}]: {1}zIssue deleting {0}: [{1}] r)z, z )r^r'r(r CallAndCollectOpErrors DeleteVersionMiscOperationErrorrbrcitemsrr Pluralizer6joinrkeysvalues)rdrerrorsr) version_patherrprintable_errors error_msgs rDeleteVersionsrs+ &g##GOOWZZ@L0,,  " "GOOWZZA #)<<> '3':':<;D(F$$2 '.. NN3/0) < IId+0023 4 6  D)00234 5 66    - -0 ]]3/f0s6D((E <EE cSnU(a [XU5nURU5nURRRnU(amUR UR :XaS[RRSRU55 URURURSS9 [X5 U(a [XRU5 gg)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)_GetPreviousVersionr\messagesr!ServingStatusValueValuesEnum servingStatusSTOPPEDr statusPrintr^ StartVersionr'r(_SetDefaultVersion_StopPreviousVersionIfApplies) all_services new_versionrdstop_previous_versionwait_for_stop_versionold_default_versionnew_version_resource status_enums rPromoteVersionrs&.:/%77 C##++HH+((K,?,??JJBf[)+K//tL[-!"5"79rc.URR$r%)r) versionUrl)r)s rGetUrir3s  # ##rcURURS5nU(dgURU/5H8nUR5(dMURUR:wdM6Us $ g)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)rEr' ListVersionsrYr()rrrdr' old_versions rrr7s`   [00$ 7'  ,,gY7k ))+++..(  8rc[R"[R5 Sn[R "SSS9nUR URURUR/USS9 [R"[R5 g ![RaOnURupVU(a [R"USUSS9 S nANn[R"5eS nAff=f) 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. c6[U[R5$r%) issubclassr_ HttpError)exc_typeunused_exc_valueunused_traceback unused_states r ShouldRetry'_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)rrdrretryerre unused_resultexc_infos rrrRs <EEF? 'mmKG $${':':KNN&K#d4 <??@  # #' ! ]!!5  $ $ &&'sABC8)0C3C33C8c (URnURRRnURUR :wa&[ R"SRU55 gUR=(d% URS:H=(d URS:H(+nU(aHUR(d7UR(d&[ R"SRU55 g[ RRSRU55 [R "UR"UR$UR&US9 U(d/[ RRSRU55 gg![R(ain[ R*"S RU[,R."U555 [ R*"S RU55 SnAgSnAff=f) 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.Nflexr?zgPrevious 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)rr!rrSERVINGr r]r^rLr basicScaling manualScalingrrr r StopVersionr'r(rrarbrc)rrdrversion_objectr is_standardrs rrrns '...##++HH+!![%8%88HH f()+ #&&6.*<*<*F6#'':57+.55  & &HH 88> 9!" **,334GHI$ **(00&))# % ! jj 9:@!:# $ !  + +9KK3::;N;>==;MOPKK"F#67999s(5FH(AH  H)%rw __future__rrrr@apitools.base.pyrr_googlecloudsdk.api_lib.apprrr googlecloudsdk.corer r googlecloudsdk.core.utilr r rrb six.movesrr`rrobjectr!rrrrrrrrrrrrrs 4&' >*36*#'*)* Z--***rEfrEj=,886.(9V$6A8<$r