@SrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKrSSK J r J r J r SSK Jr SS KJr SS KJr SS KJr SS KJr SS KJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ!r! SSK"J#r# SSK$Jr SSK%J&r& SSK%J'r' SSK%J(r( SSK)J*r* SSK+J,r, S\l-Sr.Sr/Sr0Sr1\RdS 5r3\RdS!5r4S"r5S#r6"S$S%\75r8S&\ \,RrS'\ \,Rr4S(jr:S)\;S'\<4S*jr=g)+zDAllows you to write surfaces in terms of logical RunApps operations.)absolute_import)division)print_function)unicode_literalsN)ListMutableSequenceOptional) exceptions)global_methods) api_utils) types_utils) validator)apis)connection_context)flags)serverless_operations)integration_list_printer) messages_util)stages) typekits_util)base) properties) resources)yaml)progress_tracker)runapps_v1alpha1_messagesservicedefault-runappsv1alpha1c#~# [R"USS9n[R"U5n[ X#U5v g7f)zProvide a RunAppsOperations instance to use. Arguments: args: Namespace, the args namespace. release_track: the release track of the command. Yields: A RunAppsOperations instance. T)promptN) run_flags GetRegionrGetServiceAccount_GetRunAppsOperations)args release_trackregionservice_accounts Flib/googlecloudsdk/command_lib/run/integrations/run_apps_operations.pyConnectr-<s6   tD 1&++D1/f}EEs;=c#(# [XU5v g7f)zProvide a RunAppsOperations instance to use. Arguments: region: Region to connect to. service_account: Service account to use. release_track: the release track of the command. Yields: A RunAppsOperations instance. N)r')r*r+r)s r,ConnectWithRegionr/Ms f}EEsc[R"[[5nU(d[R "S5e[ U[UUU5$)NzYYou must specify a region. Either use the `--region` flag or set the run/region property.)rGetClientInstance_RUN_APPS_API_NAME_RUN_APPS_API_VERSIONr ArgumentErrorRunAppsOperations)r*r+r)clients r,r'r']sO  ! !"46K L&   " " *      c[R"UR5nUSSnUSSnUS:XaUS:Xa[R"S5eUe)zReraises the error if with better message if it's a queueing error. Args: err: the exception to be handled. Raises: exceptions.IntegrationsOperationError: this is a queueing error. errormessagecodezunable to queue the operationiznAn integration is currently being configured. Please wait until the current process is complete and try again)jsonloadscontentr IntegrationsOperationError)errr>msgr;s r,_HandleQueueingExceptionrBmsc JJs{{ #'##  & !$ ++  / / @  )r7c \rSrSrSrSr\S5r\S5r\S5r S\ 4Sjr S;S \ S \ R4S jjrS \ S \ RS \ 4SjrSSjrSr S=Sjr!S?S \"4S!jjr#S?S \"4S"jjr$S>S#\ S$\ S%\ S&\\ 4S'jjr%S(r&S=S)\ RNS#\ S$\ S*\\ 4S+jjr(S\)\*RV4S,jr,S\ RN4S-jr-S.r.S\/4S/jr0S0r1S \ RS1\ S\ 4S2jr2S3r3S4r4S5r5S=S6\6\*RnS\ S1\ S7\\"4S8jjr8S9r9S:r:g )@r5zBClient used by Cloud Run Integrations to communicate with the API.c@XlX lX0lX@lXPlg)a[Inits RunAppsOperations with given API clients. Args: client: The API client for interacting with RunApps APIs. api_version: Version of resources & clients (v1alpha1, v1beta1) region: str, The region of the control plane. release_track: the release track of the command. service_account: the service account to use for any deployments. N)_client _api_version_region_release_track_service_account)selfr6 api_versionr*r)r+s r,__init__RunAppsOperations.__init__s L#L'+r7cUR$N)rFrKs r,r6RunAppsOperations.client <<r7c.URR$rP)rFMESSAGES_MODULErQs r,messagesRunAppsOperations.messagess << ' ''r7cUR$rP)rHrQs r,r*RunAppsOperations.regionrSr7 yaml_contentc V^^[U5n[nSU;aURS5n[R"[ R "U5RS5S9n/nSnURS05H^nURSS5nURS5n [U 5S :waM7URU S U S S .5 U S S :XdM\SnM` U(aURSSS .5 URSS9 [SU5n [R"U 5 [ R""US9n [$R&"U 5mUU4Sjn [(R*"STR-5SS9n TR/U U UUUS9 SSS5 g!,(df  g=f)z`Applies the application config from yaml file. Args: yaml_content: content of the yaml file. namezutf-8)configFrid/rtyper\redisTvpc*c US$Nrdxs r,-RunAppsOperations.ApplyYaml..s& r7keyc US$rirjrks r,rmrnsair7 selectorsc*>TRXT5 grP_UpdateDeploymentTrackertracker operation unused_statusrK stages_maps r, StatusUpdate1RunAppsOperations.ApplyYaml..StatusUpdate ##G C r7zApplying Configuration...zFailed to apply configuration.failure_message)rxtracker_update_funcappname appconfigmatch_type_namesN)dict_DEFAULT_APP_NAMEpoprConfigrdumpencodegetsplitlenappendsortmaprCheckApiEnablementsrGetComponentTypesFromSelectorsr ApplyStagesrStagedProgressTrackervaluesApplyAppConfig)rKrZapp_dictr\rrrfrres_idparts all_typesresource_stagesr|rxr{s` @r, ApplyYamlRunAppsOperations.ApplyYamls L!H D  \\& !d)00yy&--g6I C\\+r *uuT2fll3e UquQxqBC qW + uc:;12')9:I !!),99"O##O4J   / /#8   *+     s =F F(Nrrc pUR[R5 U(a?UR[R[R "UR U55 URX#U5 UR[R5 UcSSS./nSU0n U(dURS5 UR[R 5 U(a UR[R U5 UR#UUU U S9 UR[R S5 UR[R 5 URS5 g![Ran [U 5 Sn A NSn A f[Ra+n UR[RU 5 Sn A GN0Sn A ff=f![Ran [U 5 Sn A NSn A f[Ra*n UR[R U 5 Sn A NSn A ff=f) aBApplies the application config. Args: tracker: StagedProgressTracker, to report on the progress. appname: name of the application. appconfig: config of the application. integration_name: name of the integration that's being updated. deploy_message: message to display when deployment in progress. match_type_names: array of type/name pairs used for create selector. intermediate_step: bool of whether this is an intermediate step. etag: the etag of the application if it's an incremental patch. tracker_update_func: optional custom fn to update the tracker. NrgrcmatchTypeNamesz\Deployment started. This process will continue even if your terminal session is interrupted.)rcreate_selectorr_zDone.) StartStagerUPDATE_APPLICATION UpdateStagerCheckStatusMessagerI_UpdateApplication CompleteStageapi_exceptionsHttpConflictErrorrBr r? FailStageUpdateHeaderMessageCREATE_DEPLOYMENT_CreateDeployment) rKrxrrintegration_namedeploy_messagerintermediate_stepetagrr@rs r,r RunAppsOperations.ApplyAppConfigs2 v001   # #  * *!!#3  7 g$7 F556#&45')9:O  !! 2 v//0 &22NC 6   1) &22B7 F445 (E  + +$s##  0 08 1137780  + +$s##  0 07 00#667sH'E'G'G ; F  G " GG H5$ G44H5 H00H5rcURU5nURRXUS9nU=(d! [R"UR U5nU(a"[R "UR XE5nO![R"UR XE5n[R"UR U5 g)zUpdate Application config, waits for operation to finish. Args: appname: name of the application. appconfig: config of the application. etag: the etag of the application if it's an incremental patch. )r\r]rN) GetAppRefrV Applicationr GetApplicationrFPatchApplicationCreateApplicationWaitForApplicationOperation)rKrrrapp_ref applicationis_patchrys r,r$RunAppsOperations._UpdateApplication!snnW%G--++ T,KFy// gFH,,T\\7Pi-- ,,i))$,, Br7cURU5nURUR55nU(aU(a[R"S5eUR R UUUURS9n[R"URXh5n [R"URU UUS9n URU 5 g)aQCreate a deployment, waits for operation to finish. Args: appname: name of the application. tracker: The ProgressTracker to track the deployment operation. tracker_update_func: optional custom fn to update the tracker. create_selector: create selector for the deployment. delete_selector: delete selector for the deployment. zIcreate_selector and delete_selector cannot be specified at the same time.)r\createSelectordeleteSelectorserviceAccount)rN) r_GetDeploymentNameNamer r4rV DeploymentrJr CreateDeploymentrFWaitForDeploymentOperationCheckDeploymentState) rKrrxrrdelete_selectorrdeployment_name deploymentdeployment_ops dep_responses r,r#RunAppsOperations._CreateDeployment8s"nnW%G--glln=O?  $ $ 2 )) &&,, *J // gN77 / L  l+r7c|SRU[RR5RS55$)Nz{}-{}z %Y%m%d%H%M%S)formatdatetimenowstrftime)rKrs r,r$RunAppsOperations._GetDeploymentNamecs2 >>""&&(11.A r7c[R"5n[R"X15n/n/nURRnUR bUR Hn[ R"URR5n URUR:XaURU 5 URUR:XdMtURU 5 M UH3nX;dM URU5(dM"URU5 M5 UH3nX;dM UR!U5(dM"UR#U5 M5 UR%5 g)a:Updates deployment tracker with the current status of operation. Args: tracker: The ProgressTracker to track the deployment operation. operation: run_apps.v1alpha1.operation object for the deployment. tracker_stages: map of stages with key as stage key (string) and value is the progress_tracker.Stage. N)r GetMessagesGetDeploymentOperationMetadataResourceDeploymentStatusStateValueValuesEnumresourceStatusrStageKeyForResourceDeploymentr\rdstateRUNNINGrFINISHED IsWaitingr IsRunningrTick) rxrytracker_stagesrVmetadataresources_in_progressresources_completedresource_stateresource stage_names r,rv*RunAppsOperations._UpdateDeploymentTrackerhs $$&H77LH66KKN*--(99(--:L:LM >>^33 3  & &z 2 >>^44 4  $ $Z 0 .*  #(9(9((C(C8$*(  #(9(9((C(Ch'( LLNr7r\res_typereturncUR5RnURX1U5nU(aU$[R"SR U55e)zGet an integration. Args: name: the name of the resource. res_type: type of the resource. If empty, will match any type. Raises: IntegrationNotFoundError: If the integration is not found. Returns: The integration config. Integration [{}] cannot be found) GetDefaultAppr] _FindResourcer IntegrationNotFoundErrorr)rKr\rrress r,GetIntegrationGeneric'RunAppsOperations.GetIntegrationGenericsS"""$++I   Yh 7C j  - -*11$7 r7cZUR5RnURX1U5$)zGet an integration, or None if not found. Args: name: the name of the resource. res_type: type of the resource. If empty, will match any type. Returns: The integration config, if found. )rr]r)rKr\rrs r,MaybeGetIntegrationGeneric,RunAppsOperations.MaybeGetIntegrationGenerics+""$++I   ix 88r7cURHDnURRU:XdMU(aURRU:XdMBUs $ grP) resourceListr^r\rd)rKrr\rrs r,rRunAppsOperations._FindResources? %%  h#&&++2I & r7rc[R"URUR[5U/5nU(a'UR HnUR U:XdMUs $ g![Ra gf=f)zGet status of an integration. Args: res_id: ResourceID of the resource. Returns: The ResourceStatus of the integration, or None if not found N) r GetApplicationStatusrFrrresourceStatusesr^r HttpError)rKr app_statusss r,GetIntegrationStatus&RunAppsOperations.GetIntegrationStatussp 11 ,,'89F8j ,,A TTV^H-  # # sAA' A'$A''A>=A>rcUR(dg[R"URUR5$![R a gf=f)aUFetches the deployment object given a resource config. Args: resource: the resource object. Returns: run_apps.v1alpha1.Deployment, the Deployment object. This is None if the latest deployment name does not exist. If the deployment itself cannot be found via the name or any http errors occur, then None will be returned. N)latestDeploymentr GetDeploymentrFrr)rKrs r,GetLatestDeployment%RunAppsOperations.GetLatestDeploymentsJ  $ $   $ $T\\83L3L MM  # # s*?AAc *^^TR5n[R"U5nU(a6UR(a%[R "SR U55eU(dURUR5nURnTRURXG5(a*[R "[R"U55e[R"[R"XGS9S9nUR!X(5n URR"R%U5 UR'U5n U(aU/O/n U R)U 5 U H&n U R%[*R,U SS.5 M( U H.n TR/URU [*R,5 M0 TR1U 5 U(a;TRURU[*R,5n UR3UU S9 UR5U S9nUR7SS9n[8R:"SUS 9mUU4S jn[<R>"S TRA5S S 9nTRCUU[DURUUU URFS9 SSS5 U$![RHa7nURK[RL"TRNU55 UeSnAff=f!,(df  U$=f)a'Create an integration. Args: integration_type: type of the integration. parameters: parameter dictionary from args. service: the service to attach to the new integration. name: name of the integration, if empty, a defalt one will be generated. Returns: The name of the integration. z0--name is not allowed for integration type [{}].r\rdr^Trdr\ignoreResourceConfig integrationworkloadrr)createrresource_typesc*>TRXT5 grPrurws r,r|9RunAppsOperations.CreateIntegration..StatusUpdate1r~r7zCreating new Integration...z!Failed to create new integration.rrxrrrrrrrN)(rr GetTypeKit is_singletonr r4rNewIntegrationNamer] resource_typerrIntegrationAlreadyExistsrResource ResourceIDUpdateResourceConfigrrGetCreateSelectorsextendr SERVICE_TYPEEnsureWorkloadResourcesCheckCloudRunServicesExistenceBindServiceToIntegrationGetCreateComponentTypesGetDeployMessagerIntegrationStagesrrrrrrr? AddWarningRetryDeploymentMessagerI)rKintegration_type parametersrr\apptypekitrrservices_in_paramsrservicessvcr rrr|rxr@r{s` @r,CreateIntegration#RunAppsOperations.CreateIntegrations    C&&'78G $$  $ $ < C C     ' ' 3d))M #**d::  $ $  0 0 6 )11 $ / /T NH!55jKJJ""8,11$7#yH OO&'**"&  ""3::sK4L4LM''1## **g{77h&&' 55"6O--T-:N))OJ   / /%;    ,%jj!)-   , K  2 2  0 01D1Dd K  !  , Ks*:L<.J55L 2K;;LL Lc ^^TR5nTRURU5nUc*[R"[ R "U55e[R"U5n[R"URU5 /nURX&5n U (aURU 5 U(aURU5 URU5n UHPn TR!URU ["R$5 TR'U ["R$U S5 MR U(a;TRURU["R$5n UR)UU S9 U(aTRURU["R$5n U (aHUR+UU S9 TR-U5(a!TR'U ["R$U5 O%[R."SR1U55eU(aTR3U5 UR4(dUR6(aUcUc~UR9XeRR:["R$5nUHDn X;dM TR-U 5(dM"TR'U ["R$U S5 MF UR=5nUR?U S9n[@RB"SUS9mUU4Sjn[DRF"S TRI5S S 9nTRKUU[LURUUU URNS 9sSSS5 $!,(df  g=f) adUpdate an integration. Args: name: str, the name of the resource to update. parameters: dict, the parameters from args. add_service: the service to attach to the integration. remove_service: the service to remove from the integration. Raises: IntegrationNotFoundError: If the integration is not found. Returns: The name of the integration. NTr z,Service [{}] is not found among integrationsrrFrc*>TRXT5 grPrurws r,r|9RunAppsOperations.UpdateIntegration..StatusUpdater~r7zUpdating Integration...zFailed to update integration.rr)(rrr]r rrIntegrationNotFoundrGetTypeKitByResourcerValidateUpdateParametersr'rrrrrr r_AppendTypeMatcherr!UnbindServiceFromIntegrationGetCloudRunServiceServiceNotFoundErrorrr is_ingress_serviceis_backing_serviceGetBindedWorkloadsrr#r"rr$rrrrrr)rKr\r( add_serviceremove_servicer)existing_resourcer*specified_servicesr+rrr  workload_resref_svcsrrr|rxr{s` @r,UpdateIntegration#RunAppsOperations.UpdateIntegrationMs<"    C**3::t<  / /  + +D 1 001BCG ""7#;#;ZH 55 23 ,11$7% "" **g{77    " "    &## **k;#;#;h&&'' '' **nk&>&>l ,,)! -   " "> 2 2  ! ! 8 8. -- : A A    ))*<=!!""    "++ ZZ44k6N6Nh'  ,1H1H 2 2   ! ! 8 8'4 --/N55"6O))_J   / /!7    *#JJ'+xx!     s .M:: Nc ^^TR5nTRURU5nUc%[R"SR U55e[ R"U5n[R"URR5nURUR5n/nUHrnUR[R :XdM#TR#UR$5(dMEUR'[R UR$SS.5 Mt U(a!UR)U5n UR+U S9n OEURRURR$S./n URR/n [,R."U [1U5S9mUU4Sjn [2R4"S TR75S S 9n U(aUHJnTRURUR$UR5n [R8"X=5 ML U(a.TR;U U [<URUSUR>S 9 O)TRA[<URUR>S 9 SU 0nTRCXX5 SSS5 U(a URD$URR$![Ra SnGNf=f!,(df  NT=f)zDelete an integration. Args: name: str, the name of the resource to update. Raises: IntegrationNotFoundError: If the integration is not found. Returns: str, the type of the integration that is deleted. NrTr rrrc)destroy_resource_typesshould_configure_servicec*>TRXT5 grPrurws r,r|9RunAppsOperations.DeleteIntegration..StatusUpdater~r7zDeleting Integration...zFailed to delete integration.r)rxrrrrrrrrrr)#rrr]r rrrr4r4r BindingFinderrGetIDsBindedTor^rdr rr8r\rGetDeleteSelectorsGetDeleteComponentTypesrIntegrationDeleteStagesboolrrr RemoveBindingrrrr_UndeployResourcer')rKr\r)rr*bindingsbinded_from_resourcesunbind_match_type_namesriddelete_match_type_namesrr|rx binded_resrr{s` @r,DeleteIntegration#RunAppsOperations.DeleteIntegrations    C!!#**d3H  / / , 3 3D 9 228J    / /!7   (C))jj#((CHH *   X 2 ) #   ".' 6 $88    ! !' 88 " *+BCo TGJ= @  % %% [[  O  # #gH  sK #C K= K:9K:= L c*UR[R5 UR[UUUS9 UR [R5 UR 5nURURU5nU(a%URRRU5 UR[R5 UR[URURS9 UR [R5 g)zUndeploy a resource. Args: name: name of the resource delete_selector: The selector for the undeploy operation. tracker: StagedProgressTracker, to report on the progress. tracker_update_func: optional custom fn to update the tracker. )rrxrrrJN)rrUNDEPLOY_RESOURCErrrrrr]rremoveCLEANUP_CONFIGURATIONrr)rKr\rrxrr)rs r,rR#RunAppsOperations._UndeployResource-s v//0!/'   &223    C!!#**d3H jj$$X. v334!** XX  &667r7include_workloadc[R"UR5Vs/sH6nU(d*UR[RR :wdM4UPM8 sn$s snf)zReturns the list of integration type definitions. Args: include_workload: whether to include workload types Returns: An array of integration type definitions. )r IntegrationTypesrF service_type ServiceTypeWORKLOAD)rKr`r s r,ListIntegrationTypes&RunAppsOperations.ListIntegrationTypesNsU'77 E EK   $ $ (?(?(H(H H E  s 3A#A#c[R"U5nU(d+Ub*UR[RR:waU$g)zReturns the integration type definition of the given name. Args: type_name: name of the integration type include_workload: whether to include workload types Returns: An integration type definition. None if no matching type. N)r GetTypeMetadatarcrdre)rK type_namer` type_metadatas r,GetIntegrationTypeDefinition.RunAppsOperations.GetIntegrationTypeDefinition^s@ // :M!""k&=&=&F&FF  r7integration_type_filterservice_name_filterr*filter_for_typec ,[RRRR 5nU[ :Xa`[ U5(dP[R"URUR55nU(a URO/n[U5nO@[R"URUR[55nU(aU/O/nU(d/$/n UH&nU R!UR#UUUU55 M( U $)aReturns the list of integrations from the default applications. If a '-' is provided for the region, then list applications will be called. This is for the global integrations list call. Any other time the default region (either from --region or from gcloud config) will be used to fetch the default application. If the global call is not needed, then fetching from a single region will reduce latency and remove the need of filtering out non default applications. Args: integration_type_filter: if populated integration type to filter by. service_name_filter: if populated service name to filter by. region: GCP region. If not provided, then the region will be pulled from the flag or from the config. Only '-', which is the global region has any effect here. filter_for_type: the type to filter the list on. if given, the resources of that type will not be included in the list, and will only show binding to or from that type. if not given, all resources and bindings will be shown. for example, for `run integrations list`, it would filter for `service`. Returns: List of Dicts containing name, type, and services. )rVALUESapi_endpoint_overridesr Get ALL_REGIONS _IsLocalHostr ListApplicationsrFListAppsRequest applications_FilterForDefaultAppsrrrr_ParseResourcesForList) rKrnror*rpendpoint list_appsappsr)outputs r,ListIntegrations"RunAppsOperations.ListIntegrationsrsD  77??CCEH \(%;%;,, ,,,,.i(1Y # #bd "4 (d  $ $ ,,'89 ccUrd  i F mm  % %%!   Mr7c[R"URU5nU(d0$URVs0sH:nURR URR 4UR_M< sn$s snfrP)r rrFrr^rdr\r)rKrrrs r,_GetResourceStatusMap'RunAppsOperations._GetResourceStatusMapso// gFJ  i#33 3H   8;;++,hnn<3  sAA=r)focus_workloadc URc/$URRnU(d/$[R"U5nUR UR UR 55n/n[USS9GHn [R"U 5n U (a U ROU RRn X:XaMKU(aX:waMYU(aVURU R5V s/sH/n U R[ R":XdM#U R PM1 n n OOURU R5V s/sH)n SR%U RU R 5PM+ n n U(aX=;aGMUR R'S5SnUR)U RRU RR 45nUR+[,R."U RR UU SR1[U 55US95 GM U$![Ra Sn GNf=fs sn fs sn f) z>Helper function for ListIntegrations to parse relevant fields.Nc.URR$rP)r^r\rks r,rm:RunAppsOperations._ParseResourcesForList..s  r7roz{}/{}r`,)rr*r'r,latest_resource_status)r]rrrKrrr\sortedrr4r r4r'r^rd GetBindingIDsr rrrrrrRowjoin)rKr)rnror app_resourcesrSresource_statusesrrr*r'rr,r*resource_statuss r,r{(RunAppsOperations._ParseResourcesForLists zz iJJ++M  i!!-0H224>>#((3KLF=.AB44X> '.' " "8;;3C3C  + "9 #00= ={{k666 FKK=  #00= = NN6;; 4=  !4!Dxx~~c"1%f)-- ;;  X[[-- .o mm " & &'{{///xxx 01%4   ]Cr Mm % %*  s$I9"I I 0I%IIc4[R"URUR[55nUb$UR bUR R c/$UR R n[R"U5nUR5$)z]Return a list of bindings from the default application. Returns: The list of BindingData. ) r rrFrrr]rrrKGetAllBindings)rKr)rrSs r,GetBindingData RunAppsOperations.GetBindingData sy  " " dnn%67 C {cjj(CJJ,C,C,K iJJ++M!!-0H  " " $$r7c0[R"URUR[55nU(d0UR R [[R"/S9S9nUR(d[R"/S9Ul U$)zEReturns the default application. Returns: the application config. )r)r\r]) r rrFrrrVrrrr])rKr)s r,rRunAppsOperations.GetDefaultApps~  " " dnn%67 C  MM % % *11  & c ::,33cj Jr7c[RRRR SS9nUR n[ RRUX#S.SS9nU$)z~Returns the application resource object. Args: name: name of the application. Returns: The application resource object Trequired) projectsId locationsIdz'runapps.projects.locations.applicationsparams collection) rrrcoreprojectrtrHrREGISTRYParse)rKr\rlocationrs r,rRunAppsOperations.GetAppRef1s`$$,,00$0?G||H  && %?<'G Nr7c[RRRR SS9n[ R R[SU0SS9nU$)zDCreates request object for calling ListApplications for all regions.Trrzrunapps.projects.locationsr) rrrrrrtrrrru)rKrrs r,rx!RunAppsOperations.ListAppsRequestCs[$$,,00$0?G  && ' 0 'G Nr7c[RRRR SS9n[ R RUUUS.SS9nU$)zReturns the Cloud Run service reference. Args: name: name of the Cloud Run service. Returns: Cloud Run service reference Tr) namespacesId servicesIdzrun.namespaces.servicesr)rrrrrrtrrr)rKr\r service_refs r, GetServiceRefRunAppsOperations.GetServiceRefOs_$$,,00$0?G$$** # - +K r7res_namec URXU5(d@URR[R"[R "X#S9S95 gg)zMake sure resources block for the Cloud Run services exists. Args: appconfig: the application config res_name: name of the resource, res_type: type of the resource, rrN)rrrrrr)rKrrrs r,r)RunAppsOperations.EnsureWorkloadResourcescsO   i8 < <## # , ,*55  =r7c$[R"UR[R[R 5n[ R"U5nURU5nURU5sSSS5 $!,(df  g=f)zCheck for existence of Cloud Run services. Args: service_name: str, name of the service Returns: the Cloud Run service object N) rRegionalConnectionContextrHr SERVERLESS_API_NAMESERVERLESS_API_VERSIONrr-r GetService)rK service_name conn_contextr6rs r,r8$RunAppsOperations.GetCloudRunServiceysi&?? **--L  & &| 4&&|4k   { + 5 4 4s "B BcUH@nURU5nU(aM[R"SRU55e g)zCheck for existence of Cloud Run services. Args: service_names: array, list of service to check. Raises: exceptions.ServiceNotFoundError: when a Cloud Run service doesn't exist. z Service [{}] could not be found.N)r8r r9r)rK service_namesr\rs r,r 0RunAppsOperations.CheckCloudRunServicesExistencesD''-g W-- . 5 5d ;  r7c~URRRnURRRnURR UR :XagURR UR:XaURR(d[R"S5eSnURRSSS2H+nUR UR:XdMURn O SRSRURRRS555nU(aUSRU5- n[R"U5e[R"S RURR R 55e) zThrows any unexpected states contained within deployment reponse. Args: response: run_apps.v1alpha1.deployment, response to check NzConfiguration failed.r_z%Configuration failed with error: {}z z; z Logs are available at {}z0Configuration returned in unexpected state "{}".)rVDeploymentStatusr JobDetailsstatusr SUCCEEDEDFAILED errorMessager r? jobDetailsjobUrirrrr\)rKresponse dep_state job_stateurljob error_msgs r,r&RunAppsOperations.CheckDeploymentStatesW ..CCI ((==I 3 33  0 00 __ ) )334KLL c++DbD1# 99 (( ( # 2 ;AA ++hoo2288> ?i 188==  1 1) <<  1 1 < C Coo##((  r7 type_matchersignore_resource_configclUHnUSU:XdMUSU:XdM g URUUUS.5 g)Nrdr\r )r)rKrrrrmatchers r,r6$RunAppsOperations._AppendTypeMatchersF! H $H)D! 6r7c ^TR[5n[R"TRUR 5n[U4SjUR55(dX[R"SRSRURVs/sHo3RPM sn555eg![ Ra gf=fs snf)Nc3T># UHoRTR:Hv M g7frP) locationIdrH).0lrKs r, 3RunAppsOperations.VerifyLocation..sH5G||t||+5Gs%(z8Currently this feature is only available in regions {0}.z, )rrr ListLocationsrFrrrany locationsr $UnsupportedIntegrationsLocationErrorrrr)rKrrrs` r,VerifyLocation RunAppsOperations.VerifyLocationsnn./G ((w7I7IJh HX5G5GH H H  ; ; D K Kiix/A/AB/A!/ABC   I  # #   Cs+CCCC)rGrFrHrIrJ)NNNFNN)NNNrP)NN)F);__name__ __module__ __qualname____firstlineno____doc__rMpropertyr6rVr*strrrrrrrr staticmethodrvr rrrrrResourceStatusrrrr.rCrYrRrPrfrlrrrr{rr BindingDatarrrrrxrrr8r rrSelectorr6r__static_attributes__rjr7r,r5r5sZJ,&   ( (  5C5x E)E)+11 E)NCC%>%E%ECMPC6 ),V H!%  )223 8!%9 9 9)223 9*!% *11     )223 -88)889./88)445,_D@DAF[|AE8B4"16)-0'+ ;";; ;  } ;z'+ O $ 0 0O #O O sm Ob% D  %$6BB,$ y (*11 ,,$ &Z04 $T]]3  'tn  r7r5r~rcUVs/sH-oRRS[-5(dM+UPM/ sn$s snf)zReturns a dict with only default applications. Args: apps: the list of applications to filter. Returns: A list of default applications. r`)r\endswithr)r~r)s r,rzrzs1 L#!2!239J3J!K# LL Ls*<<r|c US:H$)Nzhttp://localhost:8088/rj)r|s r,rvrvs - --r7)>r __future__rrrr contextlibrr<typingrrr apitools.base.pyr rgooglecloudsdk.api_lib.runr 'googlecloudsdk.api_lib.run.integrationsr r rgooglecloudsdk.api_lib.utilrgooglecloudsdk.command_lib.runrrr$r+googlecloudsdk.command_lib.run.integrationsrrrr4googlecloudsdk.command_lib.run.integrations.typekitsr"googlecloudsdk.command_lib.runappsgooglecloudsdk.corerrrgooglecloudsdk.core.consoler6googlecloudsdk.generated_clients.apis.runapps.v1alpha1rrrrur2r3contextmanagerr-r/r'rBobjectr5rrzrrPrvrjr7r,rsK&%' 2295=?=,==@=PE>EE9*)$8\%  "  F F   F F   (``F# M (44 5 M # / /0 M.3.4.r7