T ZSrSSKrSSKrSSKrSSKrSSKJr SSKJr SSKJ r SSKJ r SSK J r SSK Jr SS KJr SS KJr SS KJr SS KJr SS KJr "SS\ R.5rSrSr"SS\5r"SS\5r"SS\5r"SS\5r"SS\5r"SS\5r "SS\5r!"S S!\ R.5r"S"r#S#r$SNS%jr%SNS&jr&S'r'S(r(S)r)S*r*SNS+jr+SNS,jr,SNS-jr-"S.S/\ R\5r/SNS0jr0S1r1"S2S3\5r2S4r3"S5S6\5r4S7r5S8r6SNS9jr7S:r8S;r9SNS<jr:S=r;SNS>jrSNSAjr?SNSBjr@SNSCjrASNSDjrBSErCSFrDSGrE\R"SH\6"5SISJS$SJSK9rG\R"SL\D"5SMSJS$SJSK9rHg)Oz-Shared resource flags for Cloud Run commands.N)global_methods)concepts)deps)util) exceptions) platforms)presentation_specs)log) properties) resources) console_iocV^\rSrSrSrU4Sjr\RS5rSr Sr U=r $)PromptFallthrough$z3Fall through to reading from an interactive prompt.c*>[[U] SUS9 g)Nfunctionhint)superr__init__)selfr __class__s 3lib/googlecloudsdk/command_lib/run/resource_args.pyrPromptFallthrough.__init__'s T+T+EcgNr parsed_argss r_PromptPromptFallthrough._Prompt*srcZ[R"5(dgURU5$r)r CanPromptr!rs r_CallPromptFallthrough._Call.s#    ! !  << $$rr) __name__ __module__ __qualname____firstlineno____doc__rabcabstractmethodr!r%__static_attributes__ __classcell__rs@rrr$s0;F  %%rrc4[RRUR[R55nUR S5SnUR S5Sn[ R"SSU5RS5R5$)aProduce a valid default service name from a container image path. Converts a file path or image path into a reasonable default service name by stripping file path delimeters, image tags, and image hashes. For example, the image name 'gcr.io/myproject/myimage:latest' would produce the service name 'myimage'. Args: image: str, The container path. Returns: A valid Cloud Run service name. :r@z [^a-zA-Z0-9-]-) ospathbasenamerstripsepsplitresubstriplower)image base_names r_GenerateServiceNamerB4ssggu||BFF34)ooc"1%)ooc"1%)  "i 0 6 6s ; A A CCrc[RR[RRU55upU(a*[RRU5upU(aM*[ U5$)aProduce a valid default service name from a local file or directory path. Converts a file or directory path into a reasonable default service name by resolving relative paths to absolute paths, removing any extensions, and then removing any invalid characters. For example, the paths /tmp/foo/bar/.. and /tmp/foo.tar.gz would both produce the service name 'foo'. A source path of "." will be expanded to the current directory name." Args: source: str, The file or directory path. Returns: A valid Cloud Run service name. )r6r7splitextabspathrB)sourcer7exts r!_GenerateServiceNameFromLocalPathrHIsR"ggrwwv67)$   &ID  d ##rc8^\rSrSrSrU4SjrSrSrSrU=r $)ResourcePromptFallthrough`zEFall through to reading the resource name from an interactive prompt.cV>[[U] SRU55 Xlg)Nz.specify the {} name from an interactive prompt)rrJrformatresource_type_lower)rrNrs rr"ResourcePromptFallthrough.__init__cs, #T38??   3rcURR5S-nURU5n[R"X#S9$)Nz name)messagedefault)rN capitalize_DefaultNameFromArgsr PromptWithDefault)rr rQ default_names rr!!ResourcePromptFallthrough._Promptks<&&113g=G,,[9L  ' ' NNrc[USS5(a[UR5$[USS5(a[UR5$g)Nr@rFr4)getattrrBr@rHrFrs rrT.ResourcePromptFallthrough._DefaultNameFromArgspsE{GT** !+"3"3 44 h - - .{/A/A BB r)rN) r'r(r)r*r+rr!rTr.r/r0s@rrJrJ`sM3O rrJc2^\rSrSrSrU4SjrSrSrU=r$)RegionPromptFallthroughxz>Fall through to reading the region from an interactive prompt.c,>[[U] S5 g)Nz-specify the region from an interactive prompt)rr\rrrs rr RegionPromptFallthrough.__init__{s !417rc[R"5n[R"U5n[R"USSSS9nX4n[ R RSRU55 U(aXQl U$)NzPlease specify a region: T)rQ cancel_optionallow_freeformzHTo make this the default region, run `gcloud config set run/region {}`. ) rGetServerlessClientInstance ListRegionsr PromptChoicer statusPrintrMregion)rr client all_regionsidxris rr!RegionPromptFallthrough._Promptsv  7 7 9F ,,V4K  ! !,  C  FJJ //5vf~! Mrr r'r(r)r*r+rr!r.r/r0s@rr\r\xsF rr\c(^\rSrSrU4SjrSrU=r$)ServicePromptFallthroughc,>[[U] S5 g)Nservice)rrprr_s rr!ServicePromptFallthrough.__init__s "D29=rrr'r(r)r*rr.r/r0s@rrprps >>rrpc(^\rSrSrU4SjrSrU=r$)WorkerPoolPromptFallthroughc,>[[U] S5 g)N workerpool)rrwrr_s rr$WorkerPoolPromptFallthrough.__init__s %t5lCrrrur0s@rrwrwsDDrrwc(^\rSrSrU4SjrSrU=r$)JobPromptFallthroughc,>[[U] S5 g)Njob)rr}rr_s rrJobPromptFallthrough.__init__s .u5rrrur0s@rr}r}s 66rr}c(^\rSrSrU4SjrSrU=r$)InstancePromptFallthroughc,>[[U] S5 g)Ninstance)rrrr_s rr"InstancePromptFallthrough.__init__s #T3J?rrrur0s@rrrs@@rrc(^\rSrSrU4SjrSrU=r$)ExecutionPromptFallthroughc,>[[U] S5 g)N execution)rrrr_s rr#ExecutionPromptFallthrough.__init__s $d4[Arrrur0s@rrrsBBrrc2^\rSrSrSrU4SjrSrSrU=r$)DefaultFallthroughzlUse the namespace "default". For Knative only. For Cloud Run, raises an ArgumentError if project not set. c*>[[U] SSS9 g)Nz]For Cloud Run on Kubernetes Engine, defaults to "default". Otherwise, defaults to project ID.r)rrrr_s rrDefaultFallthrough.__init__s  d, 1-rc`[R"5[R:Xd'[R"5[R:Xag[ USS5(dM[ R RRR5(d[R"S5eg)NrRprojectzThe [project] resource is not properly specified. Please specify the argument [--project] on the command line or set the property [core/project].) r GetPlatform PLATFORM_GKEPLATFORM_KUBERNETESrYr VALUEScorerGetr ArgumentErrorrs rr%DefaultFallthrough._Calls9#9#99  "i&C&C C  Y--    ! ! ) ) - - / /  $ $ -  rr r'r(r)r*r+rr%r.r/r0s@rrrsrrc F[R"SS[R"[R R R5[5[R"S5[R"[R RR5/S9$)N namespacezJSpecific to Cloud Run for Anthos: Kubernetes namespace for the {resource}.rname help_text fallthroughs) r ResourceParameterAttributeConfigrPropertyFallthroughr rrunrrArgFallthroughrrrrrNamespaceAttributeConfigrsx  2 2  5  " ":#4#4#8#8#B#B C     i (  " ":#4#4#9#9#A#A B   rc[R"[R5n[ 5/[RR -nXlU$r)copydeepcopyr DEFAULT_PROJECT_ATTRIBUTE_CONFIGrr)project_attribute_configrs rProjectAttributeConfigrsK!]]////<<=,+7' !!rFcXU(a [5/nO/n[R"SSUS9$);Attribute config with fallthrough prompt only if requested.rszService for the {resource}.r)rprrpromptrs rServiceAttributeConfigrs1 ,./LL  2 2 - rcXU(a [5/nO/n[R"SSUS9$)rz worker-poolzWorkerPool for the {resource}.r)rwrrrs rWorkerPoolAttributeConfigrs1 /12LL  2 2 0 rc,[R"SSS9$)N configurationz!Configuration for the {resource}.rrrrrrrConfigurationAttributeConfigr s  2 2 &I rc,[R"SSS9$)NroutezRoute for the {resource}.rrrrrRouteAttributeConfigrs  2 2 9 rc,[R"SSS9$)NrevisionzRevision for the {resource}.rrrrrRevisionAttributeConfigrs  2 2 !? rc,[R"SSS9$)Ndomainz#Name of the domain to be mapped to.rrrrrDomainAttributeConfigrs  2 2 D rcXU(a [5/nO/n[R"SSUS9$)NjobszJob for the {resource}.r)r}rrrs rJobAttributeConfigr#s1 (*+LL  2 2 ) rcXU(a [5/nO/n[R"SSUS9$)N instanceszInstance for the {resource}.r)rrrrs rInstanceAttributeConfigr/s1 -/0LL  2 2 . rcXU(a [5/nO/n[R"SSUS9$)N executionsz Execution.r)rrrrs rExecutionAttributeConfigr;s/ .01LL  2 2 [[U] SRU5SUS9 Xlg)Nz;provide the arguments `{}` and `index` on the command lineT)activeplural)rrrrMarg_name)rrrrs rr)TaskExecutionAndIndexFallthrough.__init__Hs8 *D:ELL   ;Mrc[U[R"UR5S5n[USS5nSR X#5$)Nindexz{}-{})rY concepts_utilNamespaceFormatrrM)rr prefixrs rr%&TaskExecutionAndIndexFallthrough._CallRsA ]224==A4F K$ /E >>& ((r)rFrr0s@rrrEsI))rrcZU(a [S5/nO/n[R"SSUS9$)NtasktaskszTask.r)rrrrs rTaskAttributeConfigrZs1 4V<=LL  2 2 gL rc[R"SS[R"S5[R"[ R RR5[5/S9$)NrizsThe Cloud region for the {resource}. Overrides the default `run/region` property value for this command invocation.--regionr) rrrrrr rrrir\rrrLocationAttributeConfigrdsY  2 2  E   j )  " ":#4#4#8#8#?#? @ ! #  rc8^\rSrSrSrU4SjrSrSrSrU=r $)ClusterPromptFallthroughisDFall through to reading the cluster name from an interactive prompt.c,>[[U] S5 g)Nz5specify the cluster from a list of available clusters)rrrr_s rr!ClusterPromptFallthrough.__init__vs "D2?rc[R"5[R:wag[RR R RSS9n[USS5=(d2 [RRRR5nU(aSRU5OSn[R"X#5nU(d%[R"SRU55eUVs/sHnUR!XcU5PM nn["R$"USRU5SS 9nXXn U(aSn OS RU R&5n U R)5n U R*U:waU R-5n Sn [.R0R3S RXS 95 U R55$s snf) zFallthrough to reading the cluster name from an interactive prompt. Only prompt for cluster name if the user-specified platform is GKE. Args: parsed_args: Namespace, the args namespace. Returns: A cluster name string NT)requiredcluster_locationz in [{}]r4zJNo compatible clusters found{}. Ensure your cluster has Cloud Run enabled.zGKE cluster{}:rQrbz- && gcloud config set run/cluster_location {}z[To make this the default cluster, run `gcloud config set run/cluster {cluster}{location}`. )clusterlocation)rrrr rrrrrYrrrMrMultiTenantClustersForProjectrConfigurationError_GetClusterDescriptionr rfzoneName projectId RelativeNamer rgrhSelfLink) rr rrcluster_location_msg cluster_refsccluster_refs_descsrl cluster_reflocation_help_text cluster_names rr! ClusterPromptFallthrough._Prompt{s)"8"88 $$,,00$0?G /6 8    1 1 5 5 7 0@ *+R"??L   ) ) 77=v"8  A ##AA  ! ! ''(<= C #K : @ @  ##%L' --/lJJ        !!GsGcUR5nU(dSRXAR5nX1R:waSRXAR5nU$)z"Description of cluster for prompt.z{} in {})rrMrr)rrrrresponses rr/ClusterPromptFallthrough._GetClusterDescriptionsM||~H ""8\\:h###""8->->?h Orr) r'r(r)r*r+rr!rr.r/r0s@rrrssL E"N  rrc[R"SS[R"[R R R5[5/S9$)Nrz\Name of the Kubernetes Engine cluster to use. Alternatively, set the property [run/cluster].r) rrrrr rrrrrrrClusterAttributeConfigrsJ  2 2  ;  " ":#4#4#8#8#@#@ A " $  rc2^\rSrSrSrU4SjrSrSrU=r$) ClusterLocationPromptFallthroughirc,>[[U] S5 g)Nz;specify the cluster location from a list of available zones)rrrr_s rr)ClusterLocationPromptFallthrough.__init__s *D:Erc[USS5=(d2 [RRRR 5n[ R"5[ R:XaU(a[R"5Vs/sHo3RU:XdMUPM nnU(d%[R"SRU55eUVs/sHo3RPM nn[ R""USRU5SS9nXVn[$R&R)SRU55 U$ggs snfs snf)aFallthrough to reading the cluster location from an interactive prompt. Only prompt for cluster location if the user-specified platform is GKE and if cluster name is already defined. Args: parsed_args: Namespace, the args namespace. Returns: A cluster location string rNzYNo cluster locations found for cluster [{}]. Ensure your clusters have Cloud Run enabled.zGKE cluster location for [{}]:Trz\To make this the default cluster location, run `gcloud config set run/cluster_location {}`. )rYr rrrrrrrr ListClustersrrrrMrr rfr rgrh)rr rrclusterscluster_locationsrlrs rr!(ClusterLocationPromptFallthrough._Prompts+  Y- /    ( ( , , .)"8"88\#0022ff 6L!2++ ;;A6,;O  ,448a6684  # # 299,G c #'h jj ;;A6(;Ko)>J85s E #E Errnr0s@rrrsL $$rrc[R"SS[R"[R R R5[5/S9$)Nrz`Zone in which the {resource} is located. Alternatively, set the property [run/cluster_location].r) rrrrr rrrrrrrClusterLocationAttributeConfigr  sK  2 2  D  " ":#4#4#8#8#I#I J * ,  rcn[R"S[R[5[ 5SS9$)Nz!container.projects.zones.clustersr)rr clusterId resource_name)r ResourceSpecrr rrrrGetClusterResourceSpecrs0   )99 ) +&(  rcR[R"S[5[U5SS9$)Nzrun.namespaces.servicesrs) namespacesId servicesIdr)rrrrrs rGetServiceResourceSpecr#s)   +-'/  rcP[R"S[5[5SS9$)Nzrun.namespaces.configurationsr)rconfigurationsIdr)rrrrrrrGetConfigurationResourceSpecr,s'   %+-35#  rcP[R"S[5[5SS9$)Nzrun.namespaces.routesr)rroutesIdr)rrrrrrrGetRouteResourceSpecr5s'   +-#%  rc~[R"SU(d [5O[R[ 5SS9$)Nzrun.namespaces.revisionsr)r revisionsIdr)rrrrr)is_worker_pool_revisions rGetRevisionResourceSpecr ?s5    $,-  4 4)+  rcP[R"S[5[5SS9$)Nzrun.namespaces.domainmappings DomainMapping)rdomainmappingsIdr)rrrrrrrGetDomainMappingResourceSpecr$Js'   %+-,.#  rc\[R"S[R[US9SSS9$)Nzrun.namespaces.jobsrJobv1)rjobsIdr api_version)rrrrrs rGetJobResourceSpecr*Ss/   << v .  rc\[R"S[R[US9SSS9$)Nzrun.namespaces.instancesrInstancer')r instancesIdrr))rrrrrs rGetInstanceResourceSpecr.]s/    <<)8  rc\[R"S[R[US9SSS9$)Nzrun.namespaces.executionsr Executionr')r executionsIdrr))rrrrrs rGetExecutionResourceSpecr2gs/   !<<+6:  rc\[R"S[R[US9SSS9$)Nzrun.namespaces.tasksrTaskr')rtasksIdrr))rrrrrs rGetTaskResourceSpecr6qs/   <<!0  rc`[R"S[R[U5SSS9$)Nzrun.namespaces.workerpools WorkerPoolr')r workerpoolsIdrr))rrrrrs rGetV1WorkerPoolResourceSpecr:{s/   "<<-f5   rc r[R"S[R[5[ U5SSS9$)Nz"run.projects.locations.workerPoolsr8v2) projectsId locationsId workerPoolsIdrr))rrrrrrs rGetV2WorkerPoolResourceSpecr@s5   *::)+-f5   rc [R"S[R[5[ U5[ 5SSS9$)Nz,run.projects.locations.workerPools.revisionsWorkerPoolRevisionr<)r=r>r?rrr))rrrrrrrs r#GetV2WorkerPoolRevisionResourceSpecrCs;   4::)+-f5)+( rc>[R"SS[5S9$)Nz run.projectsr)rr=)rrrrrrGetProjectResourceSpecrEs!   ') rc^[R"S[R[5SSS9$)Nzrun.projects.locationsRegionr<)r=r>rr))rrrrrrrGetRegionResourceSpecrHs-   ::)+  rc[R"S[5SS9$![Ra! [R"S[5SS9s$f=f)z*Returns a resource spec for the namespace.zrun.namespacesr)rrzrun.api.v1.namespaces)rrrr InvalidCollectionExceptionrrrGetNamespaceResourceSpecrKs\   -/!   - -  -/! s 2AAz --clusterz(Kubernetes Engine cluster to connect to.T)hiddenrprefixesrzCloud region to use.r)Ir+r,rr6r<googlecloudsdk.api_lib.runr googlecloudsdk.calliope.conceptsrrrrgooglecloudsdk.command_lib.runrr(googlecloudsdk.command_lib.util.conceptsr googlecloudsdk.corer r r googlecloudsdk.core.consoler FallthroughrrBrHrJr\rprwr}rrrrrrrrrrrrrrrrrrrrrr rrrrr r$r*r.r2r6r:r@rCrErHrKResourcePresentationSpecCLUSTER_PRESENTATIONREGION_PRESENTATIONrrrrXs4 551B54G#*)2 %(( % D*$. 10/6>8> D";D 646 @ 9@ B!:B "))"J  "       )t':':)* X0Xv ,'8,^  &*BB.    )AA    r