+dZddlmZddlmZddlmZddlmZddlmZddlZddlZddl Z ddl m Z m Z m Z mZmZddlZddlZddlZddlZddlZdd lmZmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlm Z ddl!m"Z"ddl!m#Z#ddl!m$Z$ddl!m%Z%ddl!m&Z&ddl'm(Z(ddl'm)Z)ddl*m+Z+ddl,Z,Gdde,jZej\e/Z0Gdde0Z1Gdde0Z2ejfd Gd!d"e2Z4d#Z5d$Z6ejfd Gd%d&e0Z7Gd'd(e2Z8ejfd Gd)d*e1Z9ejfd Gd+d,e1Z:ejfd Gd-d.e1Z;ejfdd/0Gd1d2e7Z<ejfd Gd3d4e1Z=ejfd Gd5d6e1Z>ejfd Gd7d8e2Z?ejfd Gd9d:e2Z@ejfd Gd;de2ZBejfd Gd?d@eAZCejfd GdAdBe1ZDejfd GdCdDe1ZEejfd GdEdFe1ZFejfd GdGdHe1ZGejfd GdIdJe0ZHejfd GdKdLe2ZIejfd GdMdNe2ZJGdOdPe2ZKejfd/dQGdRdSe4ZL ddTZM ddUZNdVZOejfd GdWdXe4ZPejfd GdYdZe2ZQGd[d\e2ZRejfd Gd]d^e4ZS dd_ZTejfd Gd`dae4ZUejfd Gdbdce4ZVejfd Gdddee4ZWejfd Gdfdge2ZXejfd Gdhdie2ZYejfd Gdjdke2ZZejfd Gdldme2Z[dnZ\ejfd Gdodpe2Z]dqZ^drZ_dsZ`ejfd Gdtdue2ZaGdvdwe2ZbGdxdye1Zcejfd Gdzd{e1Zdejfd Gd|d}e1Zeejfd/dQGd~de4Zfejfd/dQGdde4ZgdZhdZiejfd Gdde4Zjejfd Gdde2Zkejfd Gdde2Zlejfd Gdde2Zmejfd Gdde2Znejfd Gdde2Zoejfd Gdde2Zpejfd Gdde1Zqejfd Gdde1Zrejfd Gdde2Zsejfd Gdde2Ztejfd Gdde2Zuejfd Gdde2Zvejfd Gdde2Zwejfd Gdde2Zxejfd Gdde2Zyejfd Gdde2Zzejfd Gdde2Z{ejfd Gdde2Z|ejfd Gdde4Z}ejfd Gdde4Z~ejfd Gdde2Zejfd Gdde2Zejfd Gdde2Zy)z:Class for representing various changes to a Configuration.)absolute_import) annotations)division)print_function)unicode_literalsN) Collection ContainerIterableMappingMutableMapping)AnyClassVar)container_resource)job) k8s_object)revision)service) worker_pool)base) exceptions)name_generator) platforms)secrets_mapping)volumes) labels_util)repeated)run_v1_messagescbeZdZdZeej dZej dZy) ConfigChangerz5An abstract class representing configuration changes.cy)z:Returns True if any template-level changes should be made.Nselfs 4lib/googlecloudsdk/command_lib/run/config_changes.pyadjusts_templatezConfigChanger.adjusts_template7cy)zAdjust the given Service configuration. Args: resource: the k8s_object to adjust. Returns: A k8s_object that reflects applying the requested update. May be resource after a mutation or a different object. Nr!r#resources r$AdjustzConfigChanger.Adjust<r&r'N) __name__ __module__ __qualname____doc__propertyabcabstractmethodr%r+r!r'r$rr4sA= E E  r'rc eZdZdZedZy)NonTemplateConfigChangerzBAn abstract class representing non-template configuration changes.cy)NFr!r"s r$r%z)NonTemplateConfigChanger.adjusts_templateLs r'Nr,r-r.r/r0r%r!r'r$r4r4IsJ  r'r4c eZdZdZedZy)TemplateConfigChangerz>An abstract class representing template configuration changes.cy)NTr!r"s r$r%z&TemplateConfigChanger.adjusts_templateTs r'Nr6r!r'r$r8r8QsF  r'r8T)frozencVeZdZUdZdZded<ej ddZddZ y) ContainerConfigChangerzAn abstract class representing container configuration changes. Attributes: container_name: Name of the container to modify. If None the primary container is modified. N str | Nonecontainer_namecy)zMutate the given container. This method is called by this class's Adjust method and should apply the desired changes directly to container. Args: container: the container to adjust. messages_mod: Run v1 messages module. Nr!r# container messages_mods r$AdjustContainerz&ContainerConfigChanger.AdjustContainerdr&r'c|j$|jj|j}n|jj}|j ||j |S)a(Returns a modified resource. Adjusts resource by applying changes to the container specified by self.container_name if present or the primary container otherwise. Calls AdjustContainer to apply changes to the selected container. Args: resource: The resoure to modify. )r>template containersrArCMessagesModuler#r*rAs r$r+zContainerConfigChanger.Adjustts[ &##..t/B/BCi##--iH$;$;$=> Or')rAzcontainer_resource.ContainerrBtypes.ModuleType)r*z$container_resource.ContainerResource) r,r-r.r/r>__annotations__r1r2rCr+r!r'r$r<r<YsB $.*# - %  r'r<c6|D]}|j|}|S)zApply ConfigChangers to resource. It's undefined whether the input resource is modified. Args: resource: KubernetesObject, probably a Service. changes: List of ConfigChangers. Returns: Changed resource. )r+)r*changes config_changes r$ WithChangesrNs#m##H-H /r'cRt|Dcgc]}|jc}Scc}w)z3Returns True if there's any template-level changes.)anyr%)rLcs r$AdjustsTemplaterRs% ' 2'Qa  ' 2 33 2s$cpeZdZUdZeej gZded<ded<dZ ded<e d Z d Z y ) LabelChangeszRepresents the user intent to modify metadata labels. Attributes: diff: Label diff to apply. copy_to_revision: A boolean indicating that label changes should be copied to the resource's template. zClassVar[frozenset[str]]_LABELS_NOT_ALLOWED_IN_REVISIONzlabels_util.DiffdiffTboolcopy_to_revisionc|jSN)rXr"s r$r%zLabelChanges.adjusts_templates   r'c|jjtj|j j |j j}|j}|r||j _t|dr |jn |j}|jrt|dr|jjtj}t!j"||j _|j$D]}||jvs|j|= |r||jtj<|S)Nexecution_templatelabels)rVApplyrMetarG LabelsValuemetadatar] GetOrNonehasattrr\rErXgetr NONCE_LABELcopydeepcopyrU)r#r* update_resultmaybe_new_labelsrEnoncelabel_to_removes r$r+zLabelChanges.AdjustsIIOO//12>>  M%..0!1h X3 4  % %     78X#>##H$8$89#'==1A#B #CCO  /0 D 27(//(.. / Or'N) r,r-r.r/ frozensetrENDPOINT_VISIBILITYrUrJrXr0r%r+r!r'r$rTrTsS?H""#?!#; D ! !r'rTceZdZdZdZy)JobNonceChangez@Adds a new nonce to the job template, for forcing an image pull.c~tjdd|jjtj <|S)N_) separator)r GenerateNamer\r]rrer)s r$r+zJobNonceChange.Adjusts3##A5 &&s7 Or'Nr,r-r.r/r+r!r'r$roros Hr'roc"eZdZUdZded<dZy)ReplaceJobChangezyRepresents the user intent to replace the job. Attributes: new_job: New job that will replace the existing job. zjob.Jobnew_jobc|jjr/|jj|jj_|jS)aReturns a replacement for resource. The returned job is the job provided to the constructor. If resource.metadata.resourceVersion is not empty, has metadata.resourceVersion of returned job set to this value. Args: resource: job.Job, The job to adjust. )raresourceVersionrxr)s r$r+zReplaceJobChange.Adjusts;((.6.?.?.O.Odll+ <<r'Nr,r-r.r/rJr+r!r'r$rwrws  r'rwc"eZdZUdZded<dZy)ReplaceServiceChangezRepresents the user intent to replace the service. Attributes: new_service: New service that will replace the existing service. zservice.Service new_servicecZ|jjr|jj|jj_|jj D]>\}}|j t js&||jj|<@|jS)a0Returns a replacement for resource. The returned service is the service provided to the constructor. If resource.metadata.resourceVersion is not empty, has metadata.resourceVersion of returned service set to this value. Args: resource: service.Service, The service to adjust. )rarzr~ritems startswithr SERVING_GROUP)r#r*kvs r$r+zReplaceServiceChange.Adjusts((    + + / &&,,.$!Q << 00 1,-$   & &q )/   r'Nr{r!r'r$r}r}s r'r}c"eZdZUdZded<dZy)ReplaceWorkerPoolChangezRepresents the user intent to replace the worker pool. Attributes: new_worker_pool: New worker pool that will replace the existing worker pool. zworker_pool.WorkerPoolnew_worker_poolc|jjr/|jj|jj_|jS)aGReturns a replacement for resource. The returned worker pool is the worker pool provided to the constructor. If resource.metadata.resourceVersion is not empty, has metadata.resourceVersion of returned worker pool set to this value. Args: resource: worker_pool.WorkerPool, The worker pool to adjust. )rarzrr)s r$r+zReplaceWorkerPoolChange.AdjustsD((    + + ##3   r'Nr{r!r'r$rrs *) r'rF)r:initc.eZdZUdZded<fdZxZS)EndpointVisibilityChangeziRepresents the user intent to modify the endpoint visibility. Only applies to Cloud Run for Anthos. zdataclasses.InitVar[bool]endpoint_visibilityc|r5tjtjtji}n%tjtjg}t ||dy)zDetermine label changes for modifying endpoint visibility. Args: endpoint_visibility: bool, True if Cloud Run on GKE service should only be addressable from within the cluster. False if it should be publicly addressable. ) additions) subtractionsFN)rDiffrrm CLUSTER_LOCALsuper__init__)r#rrV __class__s r$rz!EndpointVisibilityChange.__init__9sX   00'2G2GHd  G,G,G+H Id GT5!r')r,r-r.r/rJr __classcell__rs@r$rr0s 10""r'rc,eZdZUdZded<ded<dZy)SetAnnotationChangezRepresents the user intent to set an annotation. Attributes: key: Annotation to set. value: Annotation value to set. strkeyvaluecL|j|j|j<|SrZ)rrrr)s r$r+zSetAnnotationChange.AdjustXs%)ZZH" Or'Nr{r!r'r$rrL ( *r'rc"eZdZUdZded<dZy)DeleteAnnotationChangezdRepresents the user intent to delete an annotation. Attributes: key: Annotation to delete. rrcT|j}|j|vr ||j=|SrZ)rrr#r*rs r$r+zDeleteAnnotationChange.Adjustgs*&&K xx; dhh  Or'Nr{r!r'r$rr]  (r'rc,eZdZUdZded<ded<dZy)SetTemplateAnnotationChangezRepresents the user intent to set a template annotation. Attributes: key: Template annotation to set. value: Annotation value to set. rrrc`|j|jj|j<|SrZ)rrErrr)s r$r+z"SetTemplateAnnotationChange.Adjustzs%.2jjH!!$((+ Or'Nr{r!r'r$rrnrr'rc"eZdZUdZded<dZy)DeleteTemplateAnnotationChangezuRepresents the user intent to delete a template annotation. Attributes: key: Template annotation to delete. rrch|jj}|j|vr ||j=|SrZ)rErrrs r$r+z%DeleteTemplateAnnotationChange.Adjusts0##//K xx; dhh  Or'Nr{r!r'r$rrrr'rceZdZUdZej eZded<ej e Z ded< d dZ d dZ d d Z y )BaseImagesAnnotationChangeaRepresents the user intent to update the 'base-images' template annotation. The value of the annotation is a string representation of a json map of container_name -> base_image_url. E.g.: '{"mycontainer":"my_base_image_url"}'. Attributes: updates: {container:url} map of values that need to be added/updated deletes: List of containers whose base image url needs to be deleted. default_factorydict[str, str]updates list[str]deletesc|r|D] }||vs||= |r|jD] \}}|||< |j||SrZ)r_constructBaseImageUrls)r#r*existing_base_image_urlsrrrAurls r$_mergeBaseImageUrlsz.BaseImagesAnnotationChange._mergeBaseImageUrlssZ) 0 0&y1#MMO.)S.1 +,  ' '2J KKr'ct|jjjDcgc]}|xsd c}dj fd|j D}|rd|zdzSdScc}w)Nz, c3@K|]\}}|vs d|d|dyw)"z":"Nr!).0rrrFs r$ zEBaseImagesAnnotationChange._constructBaseImageUrls..s/ /;esj?P!C5E7!|s {})rlrErFkeysjoinr)r#r*urlsxbase_images_strrFs @r$rz2BaseImagesAnnotationChange._constructBaseImageUrlss"++66;;=>=Qb=>Jii /3zz| O+:3 3 &ArA ?s A5c|jj}|jtjd}|r>t j |}|j|||j|j}n|j||j}|rR||jjtj<tj|jj_ |Stj|vrq|jjtj=|jjjtjk(rd|jj_ |Sz9Updates the revision to use automatic base image updates.r)rErrdrBASE_IMAGES_ANNOTATIONjsonloadsrrrr$BASE_IMAGE_UPDATE_RUNTIME_CLASS_NAMEspecruntimeClassName)r#r*rexisting_valuer new_values r$r+z!BaseImagesAnnotationChange.Adjusts$##//K$[__X%D%DbIN!%N!;** ,dllDLLi..xFiGPh##H$C$CD  7 7- O  ( (K 7    ' '(G(G H    1 1  : : ;35/ Or'N)r*revision.Revisionrrrrrrr*rrrr*r)r,r-r.r/ dataclassesfielddictrrJlistrrrr+r!r'r$rrs.K--dC'>C({((>'9>L!L!/L L  L" B' B/= Br'rceZdZUdZej eZded<ej e Z ded< d dZ d dZ d d Z y )SourcesAnnotationChangea|Represents the user intent to update the 'sources' template annotation. The value of the annotation is a string representation of a json map of container_name -> GCS objects. E.g.: '{"foo":"gs://my-bucket/my-object"}'. Attributes: updates: {container:url} map of values that need to be added/updated deletes: List of containers whose source needs to be deleted. rrrrrc|r|D] }||vs||= |r|jD] \}}|||< |j||SrZ)r_constructSources)r#r*existing_sourcesrrrArs r$ _mergeSourcesz%SourcesAnnotationChange._mergeSourcessZ) ( (y)#MMO.)S&)#,  ! !(,< ==r'ct|jjjDcgc]}|xsd c}}t j |j Dcic] \}}||vs ||c}}dScc}wcc}}w)Nr),:) separators)rlrErFrrdumpsr)r#r*rrrFys r$rz)SourcesAnnotationChange._constructSourcess"++66;;=>=Qb=>J ::**,:,$!Q!z/A,:  ? ;s A>" B /B c|jj}|jtjd}|r>t j |}|j|||j|j}n|j||j}|r.|dk7r)||jjtj<|Stj|vr%|jjtj=|S)z(Updates the revision to use zip deploys.rz{}) rErrdrSOURCES_ANNOTATIONrrrrrr)r#r*rrrrs r$r+zSourcesAnnotationChange.Adjusts##//K$[__X%@%@"ENN3$$ $dllDLLi((4<<@iY$&CLh##H$?$?@ O  $ $ 3    ' '(C(C D Or'N)r*rrrrrrrrr)r,r-r.r/rrrrrJrrrrr+r!r'r$rrs|.K--dC'>C({((>'9>>!>'> >  > ' /= r'rc4eZdZUdZdZded<dfd ZxZS)*IngressContainerBaseImagesAnnotationChangeaRepresents the user intent to update the 'base-images' template annotation. The value of the annotation is a string representation of a json map of container_name -> base_image_url. E.g.: '{"mycontainer":"my_base_image_url"}'. This class changes the base image annotation for the default container, which is either the container in a service with one container or the one with a port set in a service with multiple containers. Attributes: base_image: url of the base image for the default container or None Nr= base_imagec,|jr<|j|j|jjjxsd<n=|j j |jjjxsdt|!|Sr) rrrErAnamerappendrr+)r#r*rs r$r+z1IngressContainerBaseImagesAnnotationChange.Adjust(sm =A__dll8$$..339r: ll(++55::@bA 7>( ##r'r)r,r-r.r/rrJr+rrs@r$rrs  *j$$r'rc"eZdZUdZded<dZy)SetLaunchStageAnnotationChangezhSets launch stage annotation on a resource. Attributes: launch_stage: The launch stage to set. base.ReleaseTrack launch_stagec|jtjjk(r|S|jj|j t j<|SrZ)rr ReleaseTrackGAidrrLAUNCH_STAGE_ANNOTATIONr)s r$r+z%SetLaunchStageAnnotationChange.Adjust=sO D--000 o     :==>or'Nr{r!r'r$rr3s "!r'rc"eZdZUdZded<dZy)SetRegionsAnnotationChangezhSets regions annotation on a resource. Attributes: regions: A comma-separated list of regions. rregionscT|j|jtj<|SrZ)rrrMULTI_REGION_REGIONS_ANNOTATIONr)s r$r+z!SetRegionsAnnotationChange.AdjustQs&  CCD Or'Nr{r!r'r$rrG ,r'rc2eZdZUdZded<ded<dZdZy)RegionsChangeAnnotationChangezAdds or removes regions annotation on an existing service. Attributes: existing: the existing Service. to_add: A comma-separated list of regions to add to existing. to_remove: A comma-separated list of regions to remove from existing. rto_add to_removec|j|}dj||jtj<|SNr) GetFinalListrrrr)r#r* final_lists r$r+z$RegionsChangeAnnotationChange.Adjustes<""8,JGJxxHHCCD Or'c|jjtjxsd}|r|j dng}|j r|j j dng}|j r|j j dng}|Dcgc] }||vs| }}|j|Dcgc] }||vs| c}|Scc}wcc}w)z=Returns the final list of regions after applying the changes.Nr)rrdrrsplitrrextend)r#r* annotationexistingrrrrs r$rz*RegionsChangeAnnotationChange.GetFinalListls   !K!KL  )3z$H'+{{T[[  s #F-1^^$$S)I%&QAX,=q&>? =>s C#C8 CCN)r,r-r.r/rJr+rr!r'r$rrXs + . r'rc"eZdZUdZded<dZy)MultiRegionDomainNameChangezSets a multi-region domain name annotation on the service. Attributes: domain_name: The sandbox annotation value to set. r domain_namecT|j|jtj<|SrZ)rrrGCLB_DOMAIN_NAME_ANNOTATIONr)s r$r+z"MultiRegionDomainNameChange.Adjusts(  ??@ Or'Nr{r!r'r$rrzs r'rcJeZdZUdZded<ded<dZded<edZd Zy ) 'SetClientNameAndVersionAnnotationChangeaSets the client name and version annotations. Attributes: client_name: Client name to set. client_version: Client version to set. set_on_template: A boolean indicating whether the client name and version annotations should be set on the resource template as well. r client_nameclient_versionTrWset_on_templatec|jSrZ)r r"s r$r%z8SetClientNameAndVersionAnnotationChange.adjusts_templates   r'c|jz|j|jtj<|jrGt |j dr1|j|j jtj<|jz|j|jtj<|jrGt |j dr1|j|j jtj<|S)Nr) r rrCLIENT_NAME_ANNOTATIONr rcrEr CLIENT_VERSION_ANNOTATIONr)s r$r+z.SetClientNameAndVersionAnnotationChange.Adjusts #@D@P@Ph:<<=  '(*;*;]"K    %%j&G&GH &   :??@   '(*;*;]"K    %%j&J&JK Or'N) r,r-r.r/rJr r0r%r+r!r'r$r r s6/4    r'r c"eZdZUdZded<dZy) SandboxChangezmSets a sandbox annotation on the service. Attributes: sandbox: The sandbox annotation value to set. rsandboxch|j|jjtj<|SrZ)rrErrSANDBOX_ANNOTATIONr)s r$r+zSandboxChange.Adjusts-  !!"4"G"GH Or'Nr{r!r'r$rrrr'rc"eZdZUdZded<dZy)VpcConnectorChangezSets a VPC connector annotation on the service. Attributes: connector_name: The VPC connector name to set in the annotation. rconnector_namech|j|jjtj<|SrZ)rrErrVPC_ACCESS_ANNOTATIONr)s r$r+zVpcConnectorChange.Adjusts/  !!"4"J"JK Or'Nr{r!r'r$rrs r'rceZdZdZdZy)ClearVpcConnectorChangez1Clears a VPC connector annotation on the service.c|jj}tj|vr|tj=tj|vr|tj=|SrZ)rErrrEGRESS_SETTINGS_ANNOTATIONrs r$r+zClearVpcConnectorChange.AdjustsR##//K//;> (>> ?44 C (CC D Or'Nrur!r'r$rrs 9r'r)rr:c4eZdZUdZded<fdZdZxZS) ImageChangezjA Cloud Run container deployment. Attributes: image: The image to set in the adjusted container. rimagec Rt|di|tj|d|y)Nr"r!rrobject __setattr__)r#r"kwargsrs r$rzImageChange.__init__s% Gv tWe,r'c&|j|_yrZ)r"r@s r$rCzImageChange.AdjustContainers jjIOr'r,r-r.r/rJrrCrrs@r$r!r!s *-!r'r!cH|r|jy|D] }||vs||= yrZ)clear)mappingkeys_to_remove clear_others var_or_paths r$ _PruneMappingr0s*  MMO%   K &r'c X|r|jy|D]}|jdd\}}||vs||} | |vr&t|| |tj|| ||} g} || j D]#} || j k7s| j| %| s||=| || _y)z5Remove the specified volume mappings from the config./N)r+rsplit_CopyToNewVolumerfrgrpathr) r* res_volumes volume_mountsremovesr.external_mountsremovemountr6 volume_name new_paths key_to_paths r$_PruneManagedVolumeMappingr@sMM#q)keT - #E* / )(mmK 45  + &{399K [%% %   [ ):E"+4+k " (+r'ct|j|jj} |||<|jDchc]}|j}}||} | jD],}|j|vs|jj|.|||<|S#t$r%t j dj|wxYwcc}w)z1Copies existing volume to volume with a new name.RCannot update mount [{}] because its mounted volume is of a different source type.) _UniqueVolumeName secretNamerErKeyErrorrConfigurationErrorformatrr6r) r*r= mount_point volume_sourcer7r8new_volume_nameitemr> old_volumes r$r5r5!s& 1 1 9 9/!0M+&3%8%89%8Ttyy%8)9;'*d yy !  &"/+o    ' ' ))/ )<  :sBC .C ceZdZUdZej eZded<ej e Z ded<dZ ded <d Z y ) EnvVarLiteralChangeszRepresents the user intent to modify environment variables string literals. Attributes: updates: Updated env var names and values to set. removes: Env vars to remove. clear_others: If true clear all non-updated env vars. rMapping[str, str]rCollection[str]r9FrWr.cRt|jj|j|j |jjj |j y#t$r6}tjdj|jdd}~wwxYw)aMutates the given config's env vars to match the desired changes. Args: container: container to adjust messages_mod: messages module Returns: The adjusted container Raises: ConfigurationError if there's an attempt to replace the source of an existing environment variable whose source is of a different type (e.g. env var's secret source can't be replaced with a config map source). zpCannot update environment variable [{}] to string literal because it has already been set with a different type.rN) r0env_varsliteralsr9r.updaterrErrFrGargs)r#rArBes r$rCz$EnvVarLiteralChanges.AdjustContainerLs )$$--t||T=N=NO!!((6   ) ) CCI6ffQiD  s/A'' B&01B!!B&N) r,r-r.r/rrrrrJrr9r.rCr!r'r$rNrN>sG 1{00F' F.[..tD'?D,r'rNcDeZdZUdZded<ded<ded<dZd ed <d Zy) SecretEnvVarChangesaXRepresents the user intent to modify environment variable secrets. Attributes: updates: Env var names and values to update. removes: List of env vars to remove. clear_others: If true clear all non-updated env vars. container_name: Name of the container to update. If None, the resource's primary container is update. -Mapping[str, secrets_mapping.ReachableSecret]rrPr9rWr.Nr=r>c |jr8|jj|jjj}n |jjj}t ||j |j|jjD]\}} |j|||<tj ||S#t$r%tjdj|wxYwaMutates the given config's env vars to match the desired changes. Args: resource: k8s_object to adjust Returns: The adjusted resource Raises: ConfigurationError if there's an attempt to replace the source of an existing environment variable whose source is of a different type (e.g. env var's secret source can't be replaced with a config map source). zpCannot update environment variable [{}] to the given type because it has already been set with a different type.)r>rErFrRsecretsr0r9r.rrAsEnvVarSourcerErrFrGrPruneAnnotation)r#r*rRrreachable_secrets r$r+zSecretEnvVarChanges.Adjustzs ""--   ""++33h(DLL$*;*;<"&,,"4"4"6 )88B#7##H- O ++ EEKVF   s 'C.D)r,r-r.r/rJr>r+r!r'r$rXrXis* 98 #.*#"r'rXc4eZdZdZfdZdZdZdZxZS)ConfigMapEnvVarChangeszFRepresents the user intent to modify environment variable config maps.ct|i|_|jD]T\}}|j dd}t |dkr |j |j|||j|<V||_||_ y)aBInitialize a new ConfigMapEnvVarChanges object. Args: updates: {str, str}, Update env var names and values. removes: [str], List of env vars to remove. clear_others: bool, If true, clear all non-updated env vars. Raises: ConfigurationError if a key hasn't been provided for a source. rr3N) rr_updatesrrlenr_OmittedSecretKeyDefault_removes _clear_others)r#rr9r.rrrrs r$rzConfigMapEnvVarChanges.__init__s} GDM==?aggc1oe Ua T22489!dmmD #DM%Dr'cttjrytjdj |)Nlatestz8Missing required item key for environment variable [{}].)r IsManagedrrFrG)r#rs r$rfz/ConfigMapEnvVarChanges._OmittedSecretKeyDefaults2   ' 'BII$O r'c~|jjj}t||j|j |j jD]-\}\}} |j|j||||</|S#t$r%tjdj|wxYwr[)rErR config_mapsr0rgrhrdr_MakeEnvVarSourcerGrErrFrG)r#r*rRr source_name source_keys r$r+zConfigMapEnvVarChanges.Adjusts  ))55H(DMM4+=+=>+/==+>+>+@''{J  //  # # %{J ,A O ++ EEKVF   s &$B.B<cH|j|j||S)N)rr)configMapKeyRef) EnvVarSourceConfigMapKeySelector)r#messagesrrs r$rnz(ConfigMapEnvVarChanges._MakeEnvVarSources-   554S5I ! r') r,r-r.r/rrfr+rnrrs@r$rarasN&.@r'racBeZdZUdZdZded<dZded<dZded<dZy)ResourceChangesa\Represents the user intent to update resource limits. Attributes: memory: Updated memory limit to set in the container. Specified as string ending in 'Mi' or 'Gi'. If None the memory limit is not changed. cpu: Updated cpu limit to set in the container if not None. gpu: Updated gpu limit to set in the container if not None. Nr=memorycpugpuc<|j|j|jd<|j|j|jd<|jF|jdk(r|jj ddy|j|jd<yy)CMutates the given config's resource limits to match what's desired.Nrxry0znvidia.com/gpu)rxresource_limitsryrzpopr@s r$rCzResourceChanges.AdjustContainers {{,0KKi) xx)-i& xx S!!%%&6=6:hh !!"23 r') r,r-r.r/rxrJryrzrCr!r'r$rwrws,&*#z#z ?r'rwc Td}|j}|D]}|jdr|j|_*|jdr|j |_Q|jdr|j |_xt|||||d|vr||d|j_ d|vr||d|j _ d|vr|d|j _ d|vr||d|j_ d |vr|d |j_ |S) zCreates a probe from the given settings. Args: messages: Run v1 messages module. settings: a dict of settings for the probe. Returns: A new Run v1 probe. c||sy t||S#t$r%tjdj |wxYw)Nz&Value for key [{}] must be an integer.)int ValueErrorr ArgumentErrorrG)settingsrs r$ _ParseIntz_MakeProbe.._ParseIntsP C=  #    $ $ 2 9 9# > s .A tcpSockethttpGetgrpcztcpSocket.portz httpGet.portz httpGet.pathz grpc.portz grpc.service) ProberTCPSocketActionr HTTPGetActionr GRPCActionrsetattrportr6r)rurrprobers r$ _MakeProbers .. % c ~~k" 002eo  ",,.em  &&(ejeS)Hc23!$X/?@EOOx"8^.AugmentArgss5 D(D )c "% &#Qgaj# && &s(cr|jd}t|dk(rdj|St|dk(rUstjdstjddjt j g|Stjdj|)Nrrqr3zJTo specify a Cloud SQL instance by plain name, you must specify a project.zcTo specify a Cloud SQL instance by plain name, you must be deploying to a managed Cloud Run region.z&Malformed CloudSQL instance string: {})rrerr CloudSQLError itertoolschainrG) instance_strinstanceprojectregions r$rz)CloudSQLChanges.FromArgs..Augments##C(h X! xx!! x=A ((  ((9  xx &(98DEE&& 4 ; ;L I  r'rrrrN)rrrrr)clsrrrUrrs ``` @r$FromArgszCloudSQLChanges.FromArgs|sG$'  , *+CD"-.I"J*+CD!( ,d"  r'cfd}tj|d|}|6dj|jjt j <S)Ncjjjtj}|r|j dSgSr)rErrdrCLOUDSQL_ANNOTATIONrannotation_valr*s r$GetCurrentInstancesz3CloudSQLChanges.Adjust..GetCurrentInstancessC((4488  0 0n ##C(( ir'zcloudsql-instancesr)rParsePrimitiveArgsrrErrr)r#r*r instancess ` r$r+zCloudSQLChanges.Adjusts[++ "$7I ((9 ##$6$J$JK Or')NN)rr=rr=rUzargparse.Namespace) r,r-r.r/rJr classmethodrr+r!r'r$rrmsb$#&&##*.K.!444  44lr'rc6eZdZUdZdZded<edZdZy)ConcurrencyChangeszRepresents the user intent to update concurrency preference. Attributes: concurrency: The concurrency value to set in the resource template. If None concurrency is cleared. Nz int | None concurrencyc:||dk(rdSt|S)zReturns a ConcurrencyChanges object from the --concurrency flag value. Args: concurrency: The concurrency flag value. If 'default' concurrency is cleared, otherwise should be an integer concurrency value to set. defaultN)r)rrs r$FromFlagzConcurrencyChanges.FromFlags# {i/t FFS5E FFr'c<|j|j_|S)r|)rrEr)s r$r+zConcurrencyChanges.Adjusts$($4$4H! Or') r,r-r.r/rrJrrr+r!r'r$rrs,!+z GGr'rc"eZdZUdZded<dZy)TimeoutChangeszRepresents the user intent to update request duration. Attributes: timeout: The timeout to set in the resource template. rtimeoutc<|j|j_|S)z;Mutates the given config's timeout to match what's desired.)rrEr)s r$r+zTimeoutChanges.Adjusts $ H Or'Nr{r!r'r$rrs ,r'rc"eZdZUdZded<dZy)ServiceAccountChangeszRepresents the user intent to change service account for the revision. Attributes: service_account: The service account to set. rservice_accountc<|j|j_|S)zCMutates the given config's service account to match what's desired.)rrEr)s r$r+zServiceAccountChanges.Adjusts(,(<(>%k2K {.>> r'c4t|D] }||vs||= y)zDelete all volumes no longer being mounted. Args: mounted_volumes: set of volumes mounted in any container res_volumes: resource.template.volumes N)r)mounted_volumesr7volumes r$ _PruneVolumesr5s#[!f _$ f "r'cJeZdZUdZded<ded<ded<dZd ed <d Zd Zy) SecretVolumeChangesaTRepresents the user intent to change volumes with secret source types. Attributes: updates: Updates to mount path and volume fields. removes: List of mount paths to remove. clear_others: If true clear all non-updated volumes and mounts of the given [volume_type]. container_name: Name of the container to update. rYrrPr9rWr.Nr=r>c i}tjt}|jD]\}}||j ||j jD]\} } | j ddd} | |vrV|| j| jk7r$tjdj| | j||| u| j||| <|jD]\} } | |vrK|| } t|| dkDs| |vr9|| j| t!|| | | ||}||j | _|| }|j| jk7r{|jDchc]}|j"}}| jDchc]}|j"}}|j%|stjdj| | jDchc]}|j"}}|jD],}|j"|vs| jj |.n0t'| j|j(j*} | || <| || <ycc}wcc}wcc}w#t,$r%tjdj| wxYw)zCUpdate volumes for Cloud Run. Ensure only one secret per directory.r2r3rzaCannot update secret at [{}] because a different secret is already mounted in the same directory.zcMultiple secrets are specified for directory [{}]. Cloud Run only supports one secret per directoryrBN) collections defaultdictrrrrr4rD secret_namerrFrGAppendToSecretVolumeSourceAsSecretVolumeSourcerer;r5r6issubsetrCrErrE)r#r*r8r7r: new_volumesvolumes_to_mountsr6vol file_pathr_rHrIr=new_namerrKexisting_pathsr>s r$_UpdateManagedVolumesz)SecretVolumeChanges._UpdateManagedVolumesRsK#//5"((* c##D)+(,||'9'9';# #$$S!,Q/k  # { # . .2B2N2N N--77=vi7H   33 k+. $4#H#H $ K (<$'2&7&7&9" ]  %#K0 !+. /! 3o- K ( / / <%  ( H % , ,[ 9 {+&   -":": :4:LLALDdiiLNA/||S#t,$r%t/j0dj3|wxYw)Mutates the given config's volumes to match the desired changes. Args: resource: k8s_object to adjust Returns: The adjusted resource Raises: ConfigurationError if there's an attempt to replace the volume a mount points to whose existing volume has a source of a different type than the new volume (e.g. mount that points to a volume with a secret source can't be replaced with a volume that has a config map source). c3K|]:\}}|jk7r&|jjj<ywrZ)rr8r\values)rrexternal_containerrAs r$rz-SecretVolumeChanges.Adjust..s@& ,P((y~~%  , , 4 4 ; ; =,PsAArB) r>rErFrAr8r\rrlrr from_iterablerrrkr@r9r.r0rrrCrrErrFrGrrunionrrr^) r#r*r8r7r:r9rr_r=rHrAs @r$r+zSecretVolumeChanges.Adjusts ##..t/B/BCi##--i++33M##++33K%%& ,4,=,=,H,H,N,N,P&  O    ,,      gM7D,=,=>   M;*.););)= %)%'  ( ((*;*;*C*C  !+'2- $ $4#H#H $ K *>&/'' (<(<(>?M##H- O --//5vi/@   s !G>>.H,)r,r-r.r/rJr>rr+r!r'r$rrAs2 98 #.*#M/^Dr'rc0eZdZdZfdZdZddZxZS)ConfigMapVolumeChangeszJRepresents the user intent to change volumes with config map source types.ct|i|_|jD]E\}}|j dd}t |dkr|j d||j|<G||_||_y)a+Initialize a new ConfigMapVolumeChanges object. Args: updates: {str, [str, str]}, Update mount path and volume fields. removes: [str], List of mount paths to remove. clear_others: bool, If true, clear all non-updated volumes and mounts of the given [volume_type]. rr3rcN) rrrdrrrerrgrh)r#rr9r.rr update_valuers r$rzConfigMapVolumeChanges.__init__sv GDM 1WWS!_l \ Q D!%dmmA DM%Dr'c|jjjj}|jjj}t ||j |j|jjD]R\}\}}t||jj} |||<|j|j!||||<Tt#t$j&j)d|jj*j-D}t/|||S#t$r%tjdj|wxYw)rrBc3dK|](}|jjj*ywrZ)r8rmr)rrAs r$rz0ConfigMapVolumeChanges.Adjust..&s-& B   # # / / 6 6 8Bs.0)rErAr8rmrr0rgrhrdrrCrErrFrG_MakeVolumeSourcerGrlrrrrFrr) r#r*r8r7r6rorpr=rs r$r+zConfigMapVolumeChanges.AdjustsA%%//==IIM##++77K-0B0BC+/==+>+>+@''{J%k83D3D3L3LMk ) d "&!7!7  ! ! #[*"k+,A  %%& %..99@@B&  O /;/ O# ++ --3VD\   s 0D::.E(c|j|}|,|jj|j|||S)N)r)rr6)ConfigMapVolumeSourcerr KeyToPath)r#rurrsources r$rz(ConfigMapVolumeChanges._MakeVolumeSource/sA  + + + 6F  ll(,,3,?@ Mr'rZ)r,r-r.r/rr+rrrs@r$rrsR&,,\r'rceZdZdZdZy)NoTrafficChangez?Represents the user intent to block traffic for a new revision.c|jstjd|jj |j j |S)z5Removes LATEST from the services traffic assignments.z7--no-traffic not supported when creating a new service.) generationrrF spec_trafficZeroLatestTrafficstatuslatestReadyRevisionNamer)s r$r+zNoTrafficChange.Adjust9sK     ) ) C  ++// Or'Nrur!r'r$rr6s G r'rceZdZUdZded<dZded<ejeZ ded <eje Z d ed <dZ ded <d Z y)TrafficChangesaRepresents the user intent to change a service's traffic assignments. Attributes: new_percentages: New traffic percentages to set. by_tag: Boolean indicating that new traffic percentages are specified by tag. tags_to_update: Traffic tag values to update. tags_to_remove: Traffic tags to remove. clear_other_tags: Whether nonupdated tags should be cleared. zMapping[str, int]new_percentagesFrWby_tagrrOtags_to_updateContainer[str]tags_to_removeclear_other_tagscB|js|js |jr;|jj |j|j|j|j rw|j rD|jj}i}|j D]} |j ||||<n |j }|jj||S#t$r0tjdj||jwxYw)z0Mutates the given service's traffic assignments.zIThere is no revision tagged with [{}] in the traffic allocation for [{}].)rrrr  UpdateTagsrrTagToKeyrErrFrGr UpdateTraffic)r#r* tag_to_key percentagestags r$r+zTrafficChanges.AdjustYs d11T5J5J&&            **335  ''C +/+?+?+DK 3 ((** ))+6 O //((.sHMM(B  s $C%%9DN)r,r-r.r/rJrrrrrrrrr+r!r'r$rrFsX %$&$&7k&7&7&M.#M#4;#4#4T#J..J D r'rc"eZdZUdZded<dZy)TagOnDeployChangezThe intent to provide a tag for the revision you're currently deploying. Attributes: tag: The tag to apply to the new revision. rrc|j|jji}|jj |gd|S)z6Gives the revision that's being created the given tag.F)rrErr r)r#r*rs r$r+zTagOnDeployChange.Adjust}s9hh 1 1 6 67N $$^R? Or'Nr{r!r'r$rrsrr'rc4eZdZUdZded<fdZdZxZS)ContainerCommandChangezRepresents the user intent to change the 'command' for the container. Attributes: command: The command to set in the adjusted container. rcommandc Rt|di|tj|d|y)Nr!r!r$)r#r!r'rs r$rzContainerCommandChange.__init__s% Gv tY0r'c&|j|_yrZ)r!r@s r$rCz&ContainerCommandChange.AdjustContainers Ir'r)rs@r$r r s ,1%r'r c4eZdZUdZded<fdZdZxZS)ContainerArgsChangezRepresents the user intent to change the 'args' for the container. Attributes: args: The args to set in the adjusted container. rrUc Rt|di|tj|d|y)NrUr!r$)r#rUr'rs r$rzContainerArgsChange.__init__s% Gv tVT*r'c&|j|_yrZ)rUr@s r$rCz#ContainerArgsChange.AdjustContainers YYINr'r)rs@r$r%r%s /+r'r%h2cc4eZdZUdZdZded<dZded<dZy)ContainerPortChangeaeRepresents the user intent to change the port name and/or number. Attributes: port: The port to set, "default" to unset the containerPort field, or None to not modify the port number. use_http2: True to set the port name for http/2, False to unset it, or None to not modify the port name. **kwargs: ContainerConfigChanger args. Nr=rr use_http2cB|jr|jdn|j}|jxsd}|jdk(r|j dn&|jt |j|_|j r t|_n|j |j d|jr|js t|_|jr |g|_n|j d|jr|jjr||jjj|k(rX|jr&|j|jj_y|jjj dyyyy) z5Modify an existing ContainerPort or create a new one.rr)r containerPortNrportsr) r/ ContainerPortr.rresetrr, _HTTP2_NAMEr _DEFAULT_PORTrr)r#rArBport_msgold_ports r$rCz#ContainerPortChange.AdjustContainersC(oo <3M3M3O %%-H yyInn_%  "499~h ~~!hm  #nnV}}X33,h! iooog)"8"8"B"B    ) ) . .( :  ! !2:2H2H) * * /  * * 0 0 8 ;#Cr')r,r-r.r/rrJr,rCr!r'r$r+r+s"$ )[ 9r'r+c,eZdZUdZded<ded<dZy)ExecutionTemplateSpecChangezRepresents the intent to update field in an execution template's spec. Attributes: field: The field to update in the execution template spec. value: The value to set in the updated field. rrr rcpt|jj|j|j|SrZ)rr\rrrr)s r$r+z"ExecutionTemplateSpecChange.Adjusts' H ' ' , ,djj$**E Or'Nr{r!r'r$r7r7s * *r'r7c"eZdZUdZded<dZy)JobMaxRetriesChangezRepresents the user intent to update a job's restart policy. Attributes: max_retries: The max retry number to set in the job's restart policy. r max_retriescP|j|jj_|SrZ)r; task_templater maxRetriesr)s r$r+zJobMaxRetriesChange.Adjusts!-1-=-=H* Or'Nr{r!r'r$r:r:s r'r:c"eZdZUdZded<dZy)JobTaskTimeoutChangezRepresents the user intent to update a job's instance deadline. Attributes: timeout_seconds: The timeout in seconds to set in the job's instance deadline. rtimeout_secondscP|j|jj_|SrZ)rAr=rtimeoutSecondsr)s r$r+zJobTaskTimeoutChange.Adjust s!151E1EH. Or'Nr{r!r'r$r@r@sr'r@c"eZdZUdZded<dZy)CpuThrottlingChangezSets the cpu-throttling annotation on the service template. Attributes: throttling: The throttling annotation value to set. rW throttlingczt|j|jjtj <|SrZ)rrFrErrCPU_THROTTLE_ANNOTATIONr)s r$r+zCpuThrottlingChange.Adjusts6 DOO !!22 Or'Nr{r!r'r$rErEs r'rEc"eZdZUdZded<dZy)StartupCpuBoostChangezSets the startup-cpu-boost annotation on the service template. Attributes: cpu_boost: Boolean indicating whether CPU boost should be enabled. rW cpu_boostczt|j|jjtj <|SrZ)rrKrErrCOLD_START_BOOST_ANNOTATIONr)s r$r+zStartupCpuBoostChange.Adjust)s6 DNN !!66 Or'Nr{r!r'r$rJrJs /r'rJc"eZdZUdZded<dZy)HealthCheckChangezSets the health-check-disabled annotation on the revision template. Attributes: health_check: Boolean indicating whether the health check should be enabled. rW health_checkc|t|j |jjtj <|SrZ)rrPrErrDISABLE_HEALTH_CHECK_ANNOTATIONr)s r$r+zHealthCheckChange.Adjust:s; !! !" !!:: Or'Nr{r!r'r$rOrO0s r'rOc"eZdZUdZded<dZy)DefaultUrlChangezSets the default-url-disabled annotation on the service. Attributes: default_url: Boolean indicating whether the default URL should be enabled. rW default_urlcht|j |jtj<|SrZ)rrUrrDISABLE_URL_ANNOTATIONr)s r$r+zDefaultUrlChange.AdjustKs2FI   GH+BBC Or'Nr{r!r'r$rTrTAs r'rTc"eZdZUdZded<dZy)InvokerIamChangezSets the invoker-iam-disabled annotation on the service. Attributes: invoker_iam_check: Boolean indicating whether invoker iam should be enabled rWinvoker_iam_checkcht|j |jtj<|SrZ)rrZrrDISABLE_IAM_ANNOTATIONr)s r$r+zInvokerIamChange.Adjust\s2FI  " ""GH+BBC Or'Nr{r!r'r$rYrYRs r'rYcZeZdZUdZded<ded<ded<ded<ded<d ed <d Zd Zy )NetworkInterfacesChangeaSets or updates the network interfaces annotation on the template. Attributes: network_is_set: Boolean indicating whether network was explicitly set by the user. network: The network to set. subnet_is_set: Boolean indicating whether subnet was explicitly set by the user. subnet: The subnet to set. network_tags_is_set: Boolean indicating whether network_tags was explicitly set by the user. network_tags: The network tags to set. rWnetwork_is_setrnetwork subnet_is_setsubnetnetwork_tags_is_setr network_tagsc$|r|||<y||vr||=yyrZr!)r#mrrs r$ _SetOrClearz#NetworkInterfacesChange._SetOrClearzs! af  C& r'c|jj}i}tj|vr)t j |tjd}|j r|j|d|j|jr|j|d|j|jr|j|d|jd}|r'djt j|d }|j|tj||s#tj |vr|tj =|S) Nrr` subnetworktagsrz[{interfaces}]T) sort_keys) interfaces)rErrNETWORK_INTERFACES_ANNOTATIONrrr_rgr`rarbrcrdrGrrr)r#r*rnetwork_interfacers r$r+zNetworkInterfacesChange.Adjusts ##//K//;>** j>> ?    ()T\\B  (, D  (&$2C2CD E%%ZZ 1TB&e Z==u   9 9[ H (CC D Or'N)r,r-r.r/rJrgr+r!r'r$r^r^cs5  , +r'r^ceZdZdZdZy)ClearNetworkInterfacesChangez7Clears a network interfaces annotation on the resource.c|jj}tj|vr|tj=tj |vr|tj =|SrZ)rErrrmrrrs r$r+z#ClearNetworkInterfacesChange.AdjustsQ##//K//;> j>> ?44 C (CC D Or'Nrur!r'r$rprps ?r'rpcbeZdZUdZded<edZedZedZedZ dZ y ) CustomAudiencesChangeszfRepresents the intent to update the custom audiences. Attributes: args: Args to the command. r%rUc0t|jddS)Nadd_custom_audiencesrrUr"s r$ruz+CustomAudiencesChanges.add_custom_audiences 4994d ;;r'c0t|jddS)Nremove_custom_audiencesrvr"s r$ryz.CustomAudiencesChanges.remove_custom_audiencess 4997 >>r'c0t|jddS)Nset_custom_audiencesrvr"s r$r{z+CustomAudiencesChanges.set_custom_audiencesrwr'c0t|jddS)Nclear_custom_audiencesrvr"s r$r}z-CustomAudiencesChanges.clear_custom_audiencess 4996 ==r'cfd}tj|d|}|k|r2tj|jt j <St j jvrjt j =S)Ncjjtj}|rt j |SgSrZ)rrdrCUSTOM_AUDIENCES_ANNOTATIONrrrs r$GetCurrentCustomAudiencesz@CustomAudiencesChanges.Adjust..GetCurrentCustomAudiencess;++//  0 0n zz.)) ir'zcustom-audiences)rrrrrrr)r#r*r audiencess ` r$r+zCustomAudiencesChanges.Adjusts++  ";I  JJy ! ZCCD O  1 1X5I5I I  !G!G H Or'N) r,r-r.r/rJr0ruryr{r}r+r!r'r$rsrssa , < < ? ? < < > >r'rsc"eZdZUdZded<dZy) RuntimeChangezxSets the runtime annotation on the service template. Attributes: runtime: The runtime annotation value to set. rruntimecP|j|jj_|SrZ)rrErrr)s r$r+zRuntimeChange.Adjusts.2llH+ Or'Nr{r!r'r$rrs ,r'rc"eZdZUdZded<dZy) GpuTypeChangez{Sets the gpu-type annotation on the service template. Attributes: gpu_type: The gpu_type annotation value to set. rgpu_typec|jr3|j|jjtj<|S|jjj tjd|SrZ)rrE node_selectorrGPU_TYPE_NODE_SELECTORrr)s r$r+zGpuTypeChange.Adjustsa }} --%%j&G&GH O%%))  + +T Or'Nr{r!r'r$rrs - r'rc"eZdZUdZded<dZy)GpuZonalRedundancyChangezSets the gpu zonal redundancy annotation on the revision annotations. Attributes: gpu_zonal_redundancy: The gpu_zonal_redundancy annotation value to set. rWgpu_zonal_redundancyc|t|j |jjtj <|SrZ)rrrErr(GPU_ZONAL_REDUNDANCY_DISABLED_ANNOTATIONr)s r$r+zGpuZonalRedundancyChange.Adjust s; )) )* !!99 Or'Nr{r!r'r$rrs r'rc>eZdZUdZded<eddZ ddZy) RemoveContainersChangezYRemoves the specified containers. Attributes: containers: Containers to remove. zfrozenset[str]rFc$|t|S)zReturns a RemoveContainersChange that removes the specified containers. Args: containers: The names of containers to remove. Duplicate container names are ignored. )rl)rrFs r$FromContainerNamesz)RemoveContainersChange.FromContainerNamess y$ %%r'cv|jD]} |jj|=|S#t$rY*wxYwrZ)rFrErErHs r$r+zRemoveContainersChange.Adjust'sF__     ( ( 3% Os , 88N)rF Iterable[str]r*k8s_object.KubernetesObjectreturnr)r,r-r.r/rJrrr+r!r'r$rrs6 &&1"r'rcReZdZUdZej eZded< ddZ y)ContainerDependenciesChangeaCSets container dependencies. Updates container dependencies to add the dependencies in new_depencies. Additionally, dependencies to or from a container which does not exist will be removed. Attributes: new_dependencies: A map of containers to their updated dependencies. Defaults to an empty map. rzMapping[str, Iterable[str]]new_dependenciesc zt|jjj}|jj}|j Dcic]\}}||vr||Dcgc] }||vs| c}!}}}}|j j D]\}}|s |jjj}t|}||z }|r4tjdj|dj||rt|||<||=||j_|Scc}wcc}}}w)NzD--depends_on for container {} references nonexistent containers: {}.r)rlrErFr dependenciesrrrArrrFrGrsorted) r#r*rFrr> depends_onrQrAmissings r$r+z"ContainerDependenciesChange.AdjustCs@8,,77<<>?J$$11L+7*<*<*>*> &NJ Z ' JBJq!z/JBB*> "&!6!6! : %%//44 Z(jZ'g ++ %vi'1BC  "("4 Y  #"? &2H" O-CsD6) D13D17D61D6Nr) r,r-r.r/rrrrrJr+r!r'r$rr2s= 3D+2C2C3/1"r'rc,eZdZUdZded<ded<dZy)RemoveVolumeChangezoRemoves volumes from the service or job template. Attributes: removed_volumes: The volumes to remove. rremoved_volumesrW clear_volumesc|jr?t|jj}|D]}|jj|=|S|jD]2}||jjvs|jj|=4|SrZ)rrrErr)r#r*volsrrs r$r+zRemoveVolumeChange.Adjustns  (##++ ,d#    % %c * O++) ))11 1'' 2, Or'Nr{r!r'r$rrcs !  r'rc,eZdZUdZded<ded<dZy)AddVolumeChangezUpdates Volumes set on the service or job template. Attributes: new_volumes: The volumes to add. release_track: The resource's release track. Used to verify volume types are supported in that release track. Collection[Mapping[str, str]]rr release_trackc|jD]F}tj||jj|j |j H|SrZ)rr add_volumerErGr)r#r*rs r$r+zAddVolumeChange.AdjustsN""      # #  ! ! #    # Or'Nr{r!r'r$rr{s-,""r'rcVeZdZUdZej eZded<dZ ded<dZ y ) RemoveVolumeMountChangezRemoves Volume Mounts from the container. Attributes: removed_mounts: Volume mounts to remove from the adjusted container. rrPremoved_mountsFrW clear_mountsc|jr+t|j}|D]}|j|=|S|jD]}||jvs|j|= |SrZ)rrr8r)r#rArBrr<rs r$rCz'RemoveVolumeMountChange.AdjustContainerss ))) *d%  # #E * **)  // /%%i0+ r'N) r,r-r.r/rrrrrJrrCr!r'r$rrs/ %6K$5$5d$K./K, r'rcHeZdZUdZej eZded<dZ y)AddVolumeMountChangezvUpdates Volume Mounts set on the container. Attributes: new_mounts: Mounts to add to the adjusted container. rr new_mountsc|jD]4}d|vsd|vrtjd|d|j|d<6|S)Nrz mount-pathzrst A&"%' TT  9*1/.2(594:2<9H &C&&s{{F;*}Md#*2*$*Z"4 d#0=0$0f*d#/$0d#3$>d# 6 $ 4d/"|"0"6d# 2 $  d# 5 $  d# "7 $  d# %: $  d#D!6D$DNd#;3;$;|d#$1K$$$6d#%=$&d# !9 $  d#$<$Bd# ": $  d#!m!$!Hd# ) $  d# . $  3 E$/!(!0!" ! % !# ! !!5,!5 !5  !5 $ !5H:d#'1'$'Td#2/2$2jD2DNd#?,?$?6//*8//dd#E0E$E$d#F1F$F$d#G2G$G$d#U+U$Upd#.$4d# * $ d# 1 $ d#/$0O & d#c/c$cLK2K\ .  d#)-)$)Xd# 0 $  E$/%3%0%"E$/00"  d#.90.9$.9bd# "7 $  d# / $ d# 0 $ d# / $  d# 1 $  d# - $  d# / $  d# / $  d#939$9xd# #8 $ d#,2,$,^d# ) $ d#)$*d# 4 $  d#2$<d#-"7-$-`d#.$.d#+$.d#4$0d#1$*d#0$*d#!(!$!Hd#/$r'