DSrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK Jr SSKJr SS KJr SS KJr SS KJr SS KJr SS KJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ!r" SSK#J$r$ SSK#J%r% SS K#Jr& SSK#J'r' SSK(J)r) SSK*J+r+ SSK,J-r. SS K,Jr/ SSK,J0r0 SSK,J1r1 SSK,J2r2 SS K,J3r3 SS!K,J4r4 SS"K5J6r6 SS#K5J7r7 SS K8Jr SS$K8J9r9 SS%K8J:r: SS&K8J;r; SS'K8Jr> SS)K?J@r@ SS*KAJBrB SSKCrCS+rDS,rES-rFS.rGS//rHS0rI"S1S2\R5rK\RSBS3j5rMS4rN\R"S5S69"S7S8\.R55rQ"S9S:\.R5rSS;rT\R"S5S69"S<S=\.R55rU\R"S5S69"S>S?\.R55rV"S@SA\W5rXg)CzGAllows you to write surfaces in terms of logical Serverless operations.)absolute_import)division)print_function)unicode_literalsN)List)encoding) exceptions) list_pager) condition) configuration)domain_mapping) execution)global_methods)job) metric_names)revision)route)service)task worker_pool)apis) apis_internal)waiter)base)iam_util)config_changes) messages_util)name_generator) op_pollers)resource_name_conversion)stages)deployer)sources)log)metrics) properties) resources)progress_tracker)universe_descriptor)retryv1 allUserszroles/run.invokerzrun.services.setIamPolicyzGsha256:fd2fdc0ac4a07f8d96ebe538566331e9da0f4bea069fb88de981cd8054b8cabcc\rSrSrSrg)UnknownAPIErrorXN)__name__ __module__ __qualname____firstlineno____static_attributes__r2;lib/googlecloudsdk/command_lib/run/serverless_operations.pyr0r0Xsr8r0c#z# [R"URURUS9nUnUR(a[R "U5OSn[ R"URURUUR5S9n[UUU5v SSS5 g!,(df  g=f7f)aProvide a ServerlessOperations instance to use. If we're using the GKE Serverless Add-on, connect to the relevant cluster. Otherwise, connect to the right region of GSE. Arguments: conn_context: a context manager that yields a ConnectionInfo and manages a dynamic context that makes connecting to serverless possible. already_activated_service: bool that should be true if we already checked if the run.googleapis.com service was enabled. If this is true, we skip prompting the user to enable the service because they should have already been prompted if the API wasn't activated. Yields: A ServerlessOperations instance. )skip_activation_promptN)check_response_func http_client) rGetClientInstanceapi_name api_versionsupports_one_platform CheckResponser_GetClientInstance HttpClientServerlessOperations) conn_contextalready_activated_service op_client conn_info response_funcclients r9ConnectrL\s2$$6)y  - - 45   - -) ++- F  ||s-B;A2B*! B;* B84B;cLSRS[[555$)zAReturn a random string with unlikely collision to use as a nonce.c3j# UH)n[R"[R5v M+ g7fN)randomchoicestringascii_lowercase).0_s r9 _Nonce..s&5IfmmF**++5Is13)joinrange _NONCE_LENGTHr2r8r9_Noncer\s% 5:=5I r8T)frozenc*\rSrSr%Sr\\S'SrSrg)_NewRevisionNonceChangezEForces a new revision to get created by posting a random nonce label.noncecURURR[R'SURlU$rP)ratemplatelabelsr NONCE_LABELnameselfresources r9Adjust_NewRevisionNonceChange.Adjusts559ZZHX112!H Or8r2N r3r4r5r6__doc__str__annotations__rjr7r2r8r9r_r_sM *r8r_c,^\rSrSrSrU4SjrSrU=r$)_NewRevisionForcingChangezCForces a new revision to get created by changing the revision name.c>[RURR;a%URR[R [TU]U5$)zAdjust by revision name.)rrercrdsuperrj)rhri __class__s r9rj _NewRevisionForcingChange.AdjustsFx00777    " "8#7#7 8 7>( ##r8r2)r3r4r5r6rmrjr7 __classcell__)rus@r9rqrqsK$$r8rqc SU;$)z0Return true if the given image url is by-digest.z@sha256:r2)urls r9 _IsDigestrzs s r8c>\rSrSr%Sr\R \S'SrSr g)_SwitchToDigestChangez4Switches the configuration from by-tag to by-digest. base_revisionc[URR5(aU$URR(dU$URRURlU$rP)rzr~image image_digestrcrgs r9rj_SwitchToDigestChange.AdjustsQ##))** o    * * o"00==H Or8r2N) r3r4r5r6rmrRevisionrorjr7r2r8r9r|r|s<"""r8r|c*\rSrSr%Sr\\S'SrSrg)_AddDigestToImageChangez.Add image digest that comes from source build.rc[URR5(aU$URRS-UR-URlU$)N@)rzrcrrrgs r9rj_AddDigestToImageChange.AdjustsM""(()) o&//55;d>O>OOH Or8r2Nrlr2r8r9rrs6r8rc \rSrSrSrSr\S5rSrSr SMSjr Sr S r S r S r\R R"4S jrS rSrSrSrSrSrSrSNSjrSrSrSrSrSrS\ RBS\"S\#RHS\%\&RNS\(4 Sjr)SOS!jr*S"r+S#r,S$r-S%r.\/R`"S&S'S(9S)5r1S*r2S+r3S,r4S-r5S.r6SPS/jr7SQS0jr8SRS1jr9S2r:SNS3jr;S4rSTS7jr?STS8jr@SUS9jrAS:rBS;rCS<rDS=rES>rFS?rGS@rHSArISVSBjrJSWSCjrKSDrLSErMSF\(4SGjrNSHrOSIrPSJrQSKrRSLrSg )XrEzHClient used by Serverless to communicate with the actual Serverless API.cXl[RR5UlURR UR UR5 X0lURUl X l g)a@Inits ServerlessOperations with given API clients. Args: client: The API client for interacting with Kubernetes Cloud Run APIs. conn_context: the connection context used to create this object. op_client: The API client for interacting with One Platform APIs. Or None if interacting with Cloud Run for Anthos. N) _clientr(REGISTRYClone _registryRegisterApiByNamer?r@ _op_clientregion_region _conn_context)rhrKrFrHs r9__init__ServerlessOperations.__init__s\L''--/DNNN$$|77 O&&DL%r8c.URR$rP)rMESSAGES_MODULE)rhs r9messages_module$ServerlessOperations.messages_modules << ' ''r8cURnUR5nURUS9n[R"[ R 5 URRRU5nSSS5 [R"WU5$!,(df  N%=f![Ra n[R"U5 SnAgSnAf[R a gf=f)zlGet the revision. Args: revision_ref: Resource, revision to get. Returns: A revision.Revision object. rfN)r RelativeName RunNamespacesRevisionsGetRequestr&RecordDurationr GET_REVISIONrnamespaces_revisionsGetrrapi_exceptionsInvalidDataFromServerErrorserverless_exceptionsMaybeRaiseCustomFieldMismatchHttpNotFoundError)rh revision_refmessages revision_namerequestresponsees r9 GetRevision ServerlessOperations.GetRevisions##H --/M77]7KG  ! !,";"; <<<4488A =   x 22 = <  4 4=99!<<  + + s5$B'&B7B' B$ B''C0;CC0/C0c$UR5 g)z)Upload the code for the given deployable.N) UploadFiles)rh deployables r9UploadServerlessOperations.Uploadsr8cPUS:Xa[R"USSS9$[R"USUSS9$![Ra\nUR 5nU(aUR 5OSnU(a%[ R"SRU55 UeSnAff=f)a0Wait for a configuration to be ready in latest revision. Args: poller: A ConditionPoller object. max_wait_ms: int, if not 0, passed to waiter.PollUntilDone. Returns: A condition.Conditions object. Raises: RetryException: Max retry limit exceeded. ConfigurationError: configuration failed to rNi)wait_ceiling_ms) max_wait_msrzStill waiting: {}) r PollUntilDoner+RetryException GetConditionsDescriptiveMessager%errorformat)rhpollerrerr conditionsmsgs r9WaitForCondition%ServerlessOperations.WaitForConditions   ##FD$GG  ! ! $K   '')j0:J ) ) +tc  %,,S12 is55B% AB  B%cURnURUR5S9n[R"[ R 5 URRRU5nSSS5 WRVs/sHn[R"XR5PM sn$!,(df  N?=fs snf![Ra n[R "U5 SnAgSnAff=f)z&Returns all services in the namespace.parentN)r RunNamespacesServicesListRequestrr&rr LIST_SERVICESrnamespaces_servicesritemsrServicerrrrrh namespace_refrrritemrs r9 ListServices!ServerlessOperations.ListServices"s##H77))+8G=  ! !,"<"< =<<3388A >:B.. I.$good-. II > = I  4 4=99!<<=;$C&B.5C B?+C. B<8 CC8C33C8cURnURUR5S9n[R"[ R 5 URRRU5nSSS5 WRVs/sHn[R"XR5PM sn$!,(df  N?=fs snf![Ra n[R "U5 SnAgSnAff=f)z,Returns all configurations in the namespace.rN)r&RunNamespacesConfigurationsListRequestrr&rrLIST_CONFIGURATIONSrnamespaces_configurationsrrr Configurationrrrrrs r9ListConfigurations'ServerlessOperations.ListConfigurations/s##H==))+>G=  ! !,"B"B C<<99>>wG DCK..BP$- % %d 5. D C  4 4=99!<<=rcURnURUR5S9n[R"[ R 5 URRRU5nSSS5 WRVs/sHn[R"XR5PM sn$!,(df  N?=fs snf)z$Returns all routes in the namespace.rN) rRunNamespacesRoutesListRequestrr&rr LIST_ROUTESrnamespaces_routesrrrRouterhrrrrrs r9 ListRoutesServerlessOperations.ListRoutes>s##H55))+6G    8 8 9//44W=h :4- B;cURnURUR5S9n[R"[ R 5 URRRU5n[R"XB5sSSS5 $!,(df  g=f![Ra n[R"U5 SnAgSnAf[R a gf=f) < ; ;  4 4=99!<<  + + ;$B%;B B% B"B%"B%%C.9CC.-C.cURn[RRRR SS9nSUSUR SU3nURRUSS9n[R"[R5 [R"URURR URR"5nU[$R&R(:XGa!UR+U5n U R,(aj[.R0"U R,5n [.R2"UR4U 5n [6R4"XR5sSSS5 $U R8(aj[.R0"U R85n [.R2"UR4U 5n [6R4"XR5sSSS5 $UR;U5sSSS5 $[<R>"X5n [.R0"U R,5n [.R2"UR4U 5n [6R4"XR5sSSS5 $!,(df  g=f![@RBa n [DRF"U 5 Sn A gSn A f[@RHa gf=f) rTrequired projects/ /locations/ /operations/!run.projects.locations.operations collectionN)%rr'VALUEScoreprojectrrrParseRelativeNamer&rrWAIT_OPERATIONr WaitOperationPollerrprojects_locations_servicesprojects_locations_operationsr ReleaseTrackALPHAPollrrMessageToPyValuePyValueToMessagerrmetadatarrrrrrrr) rh operation_idr release_trackrrop_nameop_refr operationas_dictas_pbrs r9 WaitService ServerlessOperations.WaitServiceZs7##H$$,,00$0?G G9K ~\,P ^^ - -?.F  ! !,"="= >//  LL 4 4 LL 6 6  D--33 3kk&))  // 0B0BCG--h.>.>HE??5*>*>? ? >!!// 0B0BCG--h.>.>HE??5*>*>?% ? >(??;/) ? >,**6:)--i.@.@A'++H,<, >6  4 4=99!<<  + + sc.$J.C,J> J.A1J9 J.J J.A6J J. J+'J.+J..K7KK76K7cURn[US5(a@URRURSUR 0SS9R 5nOUR 5nURUS9n[R"[R5 URRRU5nSSS5 [R "WU5$!,(df  N%=f!["R$a n[&R("U5 SnAgSnAf["R*a gf=f)zBReturn the relevant Configuration from the server, or None if 404. servicesId namespacesIdzrun.namespaces.configurationsparamsrrN)rhasattrrParserrr%RunNamespacesConfigurationsGetRequestr&rrGET_CONFIGURATIONrrrr rrrrrr)rhservice_or_configuration_refrrfconfiguration_get_requestconfiguration_get_responsers r9GetConfiguration%ServerlessOperations.GetConfigurations##H+\:: ^^ ! ! & 1 1:GG 5 "    * 6 6 8d ( N N !O!   ! !,"@"@ A%)\\%K%K%O%O %& " B ( ()CX NN B A  4 4=99!<<  + + s6>$C8"&C'C8' C51C88E D''EEc$URn[US5(a@URRURSUR 0SS9R 5nOUR 5nURUS9n[R"[R5 URRRU5nSSS5 [R "WU5$!,(df  N%=f!["R$a gf=f)z:Return the relevant Route from the server, or None if 404.rrzrun.namespaces.routesrrN)rrrrrrrRunNamespacesRoutesGetRequestr&rr GET_ROUTErrrrrrr)rhservice_or_route_refrrfroute_get_requestroute_get_responses r9GetRouteServerlessOperations.GetRoutes##H#\22 ^^ ! !  ) )2?? - "    " . . 0d >>D>I  ! !,"8"8 9!\\;;??   :[[+X 66 : 9  + + s*>$C8"&C'C8' C51C88DDcURnUR5nURUS9n[R"[ R 5 URRRU5 SSS5 g!,(df  g=f![Ra0 [R"SRUR55ef=f)zDelete the provided Service. Args: service_ref: Resource, a reference to the Service to delete Raises: ServiceNotFoundError: if provided service is not found. rN Service [{}] could not be found.)rr"RunNamespacesServicesDeleteRequestr&rrDELETE_SERVICErrDeleterrrServiceNotFoundErrorrr)rhrr service_nameservice_delete_requests r9 DeleteService"ServerlessOperations.DeleteServices##H++-L%HH I  ! !,"="= > ((//0FG ? > >  + + ! 6 6 , 3 3K4J4J K *$B&B7B B BBACcURnUR5nURUS9n[R"[ R 5 URRRU5 SSS5 g!,(df  g=f![Ra0 [R"SRUR55ef=f)zDelete the provided Revision. Args: revision_ref: Resource, a reference to the Revision to delete Raises: RevisionNotFoundError: if provided revision is not found. rNz!Revision [{}] could not be found.)rr#RunNamespacesRevisionsDeleteRequestr&rrDELETE_REVISIONrrr'rrrRevisionNotFoundErrorr revisionsId)rhrrrrs r9DeleteRevision#ServerlessOperations.DeleteRevisions##H --/M:: :NG  ! !,">"> ? ))009 @ ? ?  + + ! 7 7 - 4 4\5M5M N r-cURnURUR5SR[R U5S9nUR RRU5nURVs/sHn[R"Xc5PM sn$s snf![Ra n[R"U5 SnAgSnAff=f)z*Return all revisions with the given nonce.z{} = {})r labelSelectorN)r!RunNamespacesRevisionsListRequestrrrrerrrrrrrrr)rhrrarrrrrs r9GetRevisionsByNonce(ServerlessOperations.GetRevisionsByNonces##H88))+&&x';';UC9G=2277@h1 or 0 after a short timeout, use the latestCreatedRevision in status. Arguments: template: Revision, the revision template to get the base revision of. May have been derived from a Service. metadata: ObjectMeta, the metadata from the top-level object status: Union[ConfigurationStatus, ServiceStatus], the status of the top- level object. Returns: The base revision of the configuration or None if not found by revision name nor nonce and latestCreatedRevisionName does not exist on the Service object. Nrzrun.namespaces.revisionsrii)sleep_msrzrun.namespacesrzrun.api.v1.namespaces)rf functoolspartialrr namespacer RevisionNameBasedPoller GetResultrrr+rrdgetrrer(InvalidCollectionExceptionNonceBasedRevisionPollerlatestCreatedRevisionNamer) rhrcrstatusr~base_revision_namerevision_ref_getterrbase_revision_noncerrs r9_GetBaseRevision%ServerlessOperations._GetBaseRevisions2M!  '// NN "H$6$671  33DN((  Sd   $OO//0D0DdK    NN00""/?1M66tK& **"" -   ) )~~++  , ,"H$6$671, ((6 K ! !   55  NN00""/F1M ##   sBA1E=$F&;G=FF8GGGGG-,G-c[URR5(dTURURURUR 5nU(aUR [U55 ggg)zEMake config_changes include switch by-digest image if not so already.N)rzrcrrIrrEappendr|)rhservrr~s r9_EnsureImageDigest'ServerlessOperations._EnsureImageDigestCs] T]](( ) )++ -- m 3MBC  *r8c URnU(a[R"XB5nUR5nUR UR 5UU(aSOSS9n[ R"[R5 URRRU5n SSS5 [R"W U5$U(d/[R "SR#UR$55e[RR'URUR(5n UR$U lUR-5R5n [R"X5n UR/U R 5U U(aSOSS9n [ R"[R05 URRR3U 5n SSS5 [R"W U5$!,(df  GNf=f!,(df  N7=f![4R6a n[R8"U5 SnAgSnAf[4R:a4n[<R>"[R@"U55 SnAgSnAf[4RBGan[DRF"U5n[IURJS5(aSURJRL;aUe[NRPRRRTRW5nSnUS :Xau[XRZ"5nUVs/sH)nS R#UR*UR\5PM+ Os snfnnUS R#S R_U55- nOUS :Xa{[XR`"URb5nURdU;aJUVs/sHnSR#U5PM Os snfnnUSR#S R_U55- nO US:XaUS- n[Rf"U5eSnAf[4R@an[NRPRRRTRW5nUS :Xa[<R>"U5 [Rh"U5nSR_URjVs/sHnUSPM Os snfsn5nU(d URln[Rn"SR#[qURj5S:a SU55eSU55eSnAff=f)a Apply config_changes to the service. Create it if necessary. Arguments: service_ref: Reference to the service to create or update config_changes: list of ConfigChanger to modify the service with with_code: bool, True if the config_changes contains code to deploy. We can't create the service if we're not deploying code. serv: service.Service, For update the Service to update and for create None. dry_run: bool, if True only validate the change. Returns: The Service object we created or modified. allN)rrfdryRunr$)rrrRdomain_detailsrun.googleapis.com"Deployment endpoint was not found.gkez * {} in {}z Perhaps the provided cluster was invalid or does not have Cloud Run enabled. Pass the `--cluster` and `--cluster-location` flags or set the `run/cluster` and `run/cluster_location` properties to a valid cluster and zone and retry. Available clusters: {} managed* {} The provided region was invalid. Pass the `--region` flag or set the `run/region` property to a valid region and retry. Available regions: {} kubernetesz Perhaps the provided cluster was invalid or does not have Cloud Run enabled. Ensure in your kubeconfig file that the cluster referenced in the current context or the specified context is a valid cluster and retry.z messagez Error{}: {} srN)9rconfig_changes_mod WithChangesr*RunNamespacesServicesReplaceServiceRequestMessager&rrUPDATE_SERVICErrReplaceServicerrrr(rrNewrrfParent"RunNamespacesServicesCreateRequestCREATE_SERVICECreaterrrHttpBadRequestErrorr reraise HttpErrorrapi_lib_exceptions HttpExceptionrpayloadrSr'rrunplatformrr ListClusterszonerY ListRegionsrrDeploymentFailedErrorKubernetesExceptionParsercausesrKubernetesErrorlen)rhrr with_coderMdry_runr serv_nameserv_update_requpdatednew_servrserv_create_req raw_servicer parsed_errrq error_msg all_clusterscclusters all_regionsrregions k8s_errorrws r9_UpdateOrCreateService+ServerlessOperations._UpdateOrCreateServiceLsR&##HY !--dC,,. "MMLLN$E$N   # #L$?$? @LL44CC 'Aw11%::077 8N8NO  ??&&t||[5M5MN#.. ##%224%11(K"EE$$&#5F   # #L$?$? @ 88??P+A{H55/A @*A @  4 4=99!<<  - -=.88;<<  + +&C%33A6j *$$&6 7 7"j&8&8&G&GG""&&//335h6i U %224 AMNAL''7NN ( )/tyy/B(C   y $00A <<{ */:;{!V]]1%{;'; )*0 '0B)C  ) | # ,  " 7 7 BB  # # ""&&//335h Y 1'AA!Di{{)2B2BC2BQAiL2BCDf  ! 1 1  ! !))*Q.c  46   sA9H/&H -H/ C;H/&H-H/ HH/ H,(H//U,IU,5*J$$U, =A*U''U,cUc)[R"[R"5SSS9nUR U5nU(d/[ R "SRUR55eURXSU5nU(dURR5(aU$URbU(a"[R"URU5n O-[R"URURUU5n [ R""XUS9n UR%U 5 U R'5nU$)z"Update traffic splits for service.Taborted interruptableaborted_messager$F)rM)r)NoOpStagedProgressTrackerr"UpdateTrafficStagesrrr(rrrrIsReadyrr<r=r r ServiceConditionPollerr GetResource) rhrrtrackerasyn is_verboserrM updated_servgetterrs r9 UpdateTraffic"ServerlessOperations.UpdateTraffics% ::  $ $ &#g ??; 'D  ! 6 6 , 3 3K4J4J K ..UDL   ( ( * *  " " *j""4??K@""     % %     00  f F#'')l r8cUb UROSnSR[US-5RS5[R "55nUR S[U55 g)z?Get a new revision forcing config change for the given service.Nrz{}-{}r]) generationrrnzfillr GenerateNameinsertrq)rhrMrcurr_generationrevision_suffixs r9_AddRevisionForcingChange.ServerlessOperations._AddRevisionForcingChanges[)-)9dooqOnn Oa  &&q)>+F+F+HO!6GHr8cLUR[R"U/S95 g)zEDelete the base image revision level annotation for source container.)deletesNrLr_BaseImagesAnnotationChange)rhrsource_container_names r9"_DeleteRevisionBaseImageAnnotation7ServerlessOperations._DeleteRevisionBaseImageAnnotations&55*+ r8cLUR[R"X20S95 g)awReplace the base image in the config changes with the rectified base image returned from build. Args: config_changes: list, objects that implement Adjust(). base_image_from_build: The base image from build to opt-in automatic build image updates. ingress_container_name: The name of the ingress container that is build from source. This could be empty string. updatesNr)rhrbase_image_from_buildingress_container_names r9_ReplaceOrAddBaseImage+ServerlessOperations._ReplaceOrAddBaseImages&55+C r8cU(aIUSRS/5H0nURS5(dMURSS5Ss $ g)z,Get the function target from the build pack.renvszGOOGLE_FUNCTION_TARGET==r]N)rA startswithsplit)rhpackenv_vars r9_GetFunctionTargetFromBuildPack4ServerlessOperations._GetFunctionTargetFromBuildPacksK !W[[,'   7 8 8sA&q) )- r8rrprefetchr generate_namecSnUSSnU(aD[R"[R"UR 55UR 5nOUbUR U5nU(aURXg5 O"UR[[555 UR[R5 URS5 URX'SUSS9 UR![R5 g)z0Validate the service in dry run before building.NzValidating Service...T)r{)rrcopydeepcopyrbrrrrLr_r\ StartStager"VALIDATE_SERVICEUpdateHeaderMessager CompleteStage)rhrrrrrsvcvalidate_config_changess r9"_ValidateServiceBeforeSourceDeploy7ServerlessOperations._ValidateServiceBeforeSourceDeploys C,Q/ OO --((* +T-A-A c   OOK (c $$SB$$%.s$AOA*Q*66 7 7s')z0Service [{}] is in the process of being deleted.) dependenciesrM):rr)rr" ServiceStagesr UPLOAD_SOURCEr$ IsGcsObjectrr ArchiveTypeTARr GetGsutilUrirLr_SourcesAnnotationChangerrGetContextWithRegionOverriderr# CreateImage_ClearRunFunctionsAnnotations_AddRunFunctionsAnnotationsrranyAdjustsTemplaterr_r\rNrdeletionTimestamprrurrr_HandleAllowUnauthenticated _HandleIaprrrr<r=r r rServiceDependenciesr run_conditionGetNonTerminalMessagesr AddWarningr)/rhrrrrrallow_unauthenticatedmultiregion_regions for_replacerrr build_region build_sourcerepo_to_createalready_activated_servicesr{rdelegate_builds base_imagebuild_service_account!deploy_from_source_container_namebuild_worker_poolbuild_machine_typerrr source_bucketkms_key iap_enabled skip_buildrequires_buildr source_pathsourcenew_connrrrrrrM with_imageupdated_servicerrrs/ r9ReleaseService#ServerlessOperations.ReleaseService8sZt"-@j.N  )T\\F ::   #4/'5$0$<*"0"<%T1  # gJ --.   \ * *## 9 #         # ##  !**62   4 48+F  F001 ##@@Hh  // (M         &     !    $  %      *   C 8D **>: (()+1))!#!--N%= )  5lCDc d d __[ )d  55djAOj  + +N ; ;   ( (~ >    7 A B  +>  ! !$ 7  //; ! 7 7 < C C$$   11ZwO  $$,? OOKowG   # # + + - -  % % -""4??K@""     ( (     00  112EF f  F#55f6J6J6LM#3N**,o o 8s/AR=AR RcUbUbURXX45$Ub|UR[R5 UR [RS5 UR UU[ [5 UR[R5 gg![RaO SRU(aSOSURURS9nUR[RUS9 gf=f)zHandle SetIamPolicy call(s).NrNzSetting IAM policy failed, try "gcloud beta run services {}-iam-policy-binding --region={region} --member=allUsers --role=roles/run.invoker {service}"addremoverrwarning_message)&_HandleMultiRegionAllowUnauthenticatedrr"SERVICE_IAM_POLICY_SET UpdateStageAddOrRemoveIamPolicyBinding"ALLOW_UNAUTH_POLICY_BINDING_MEMBER ALLOW_UNAUTH_POLICY_BINDING_ROLErrrlrrrCompleteStageWithWarning)rhrrrrrs r9r0ServerlessOperations._HandleAllowUnauthenticated9s(-@-L  8 8 .A( 6889F992> ((  ! . ,  f;;<) % %   228&.H||#..393  ((  ) )? )   sA:BA C<;C<c UR[R5 SnUHNnUR[RSR U55 UR UU[ [US9 MP U(d UR[R5 gUR[RUS9 g![Ra6 U(d'SR U(aSOSUURS9nMXV- nMf=f) z4Handle SetIamPolicy calls for Multi-Region Services.Nz Setting IAM policy for region {})region_overridezSetting IAM policy failed, try "gcloud beta run services {}-iam-policy-binding --region=[region] --member=allUsers --role=roles/run.invoker {service}" for regions: {region}rrrr) rr"rrrrrrrrlrrr)rhrrrrrrs r9r;ServerlessOperations._HandleMultiRegionAllowUnauthenticatedZs v445O%$  ) ) . 5 5f =  ((  ! . ," ) &6  F99: &&  ' ''# % % $Jv0%h%00   #/ $sA B<DDcl[R"5RnU(a SUSUS3$SUS3$)a-Returns the service agent for the given project. For Universe Projects, the format will look like service-{project_num}@gcp-sa-iap.{project_prefix}iam.gserviceaccount.com FOR GDU format will look like service-{project_num}@gcp-sa-iap.iam.gserviceaccount.com Args: project_num: The project number. zserviceAccount:service-z @gcp-sa-iap.z.iam.gserviceaccount.comz#@gcp-sa-iap.iam.gserviceaccount.com)r*GetUniverseDomainDescriptorproject_prefix)rh project_numr"s r9GetServiceAgent$ServerlessOperations.GetServiceAgentsG 779HH&{m<?OOg hh $[M1T UUr8crURUR5nUbUR[R5 UR [RS5 U(aUR X5 OURUSU[5 UR[R5 gg![RaqnU(aURS:XaSnO/SRU(aSOSURUURS 9nUR![RUS 9 SnAgSnAff=f) zHandle IAP changes.NrNFizIAP has not been successfully enabled. If this is the first time you're enabling IAP in this project, please wait a few minutes for the service agent to propagate, then try enabling IAP again on this service.zSetting IAM policy failed, try "gcloud run services {}-iam-policy-binding --region={region} --member={member} --role=roles/run.invoker {service}"rr)rmemberrr)r$r>rr"SERVICE_IAP_ENABLEr_AddIamPolicyBindingWithRetryrrrrrl status_coderrrr)rhrrr riap_service_agentrrs r9rServerlessOperations._HandleIaps,,_-F-FG$ 6445F55r:   , ,[ L  * *.  f778 % % AMMS0" 55;V&%H*%00 6<6  ((  % % ) + sBB11D6A'D11D6r-i:) max_retrialsr;c2URUSU[5$)NT)rr)rhrr+s r9r)2ServerlessOperations._AddIamPolicyBindingWithRetrys  + +T,.N r8cURnURUR5S9n[R"[ R 5 URRRU5n[R"XB5sSSS5 $!,(df  g=f![Ra n[R"U5 SnAgSnAf[R a gf=f)?Return the relevant WorkerPool from the server, or None if 404.rN)r"RunNamespacesWorkerpoolsGetRequestrr&rrGET_WORKER_POOLrnamespaces_workerpoolsrworker_pool_lib WorkerPoolrrrrr)rhworker_pool_refrworker_pool_get_requestworker_pool_get_responsers r9 GetWorkerPool"ServerlessOperations.GetWorkerPools##H&II  ) ) +J   ! !,">"> ?#'<<#F#F#J#J #$  ))*BM @ ? ?  4 4=99!<<  + + rcURnURUR5S9n[R"[ R 5 URRRU5nSSS5 WRVs/sHn[R"XR5PM sn$!,(df  N?=fs snf![Ra n[R "U5 SnAgSnAff=f)z(Returns all worker pools in the project.rN)r#RunNamespacesWorkerpoolsListRequestrr&rrLIST_WORKER_POOLSrr4rrr5r6rrrr)rh project_refrrrrrs r9ListWorkerPools$ServerlessOperations.ListWorkerPoolss##H::'');G=  ! !,"@"@ A<<66;;GD BBJAO/ $ $T 4 B A  4 4=99!<<=rc6Uc)[R"[R"5SSS9nUR U5nU(aFUR R b/[R"SRUR55eURXXe5nU(d(U(d!URR5(aU$URc"[R "URU5nO+[R "UR"UR5n[$R&"UUUS9n UR)U 5 [*R,"U R/55Hn UR1U 5 M U R35nU$)a#Replace the given worker pool in prod using the given config_changes. Args: worker_pool_ref: Resource, the worker pool to replace. config_changes: list, objects that implement Adjust(). tracker: StagedProgressTracker, to report on the progress of releasing. asyn: bool, if True, return without waiting for the worker pool to be updated. dry_run: bool. If true, only validate the configuration. Returns: worker_pool.WorkerPool, the worker pool as returned by the server on the POST/PUT request to create/update the worker pool. Trrz4Worker pool [{}] is in the process of being deleted.r)r)rr"WorkerPoolStagesr:rrrrur workerpoolsId_UpdateOrCreateWorkerPoolrrrr<r=WaitWorkerPoolr WorkerPoolConditionPollerrrrrrr) rhr7rrrr{rupdated_worker_poolrrrs r9ReplaceWorkerPool&ServerlessOperations.ReplaceWorkerPoolsh, ::  ! ! ##g $$_5K{++==I ! 7 7 @ G G++  88   ' ' / / 1 1""''/  !3!3_Ef    2??f 1 1'F  &!33F4H4H4JK L ,,. r8cURn[RRRR SS9nSUSUR SU3nURRUSS9n[R"[R5 [R"URURR URR"5n[$R&"Xe5n[(R*"UR,5n[(R."UR0U5n [2R0"XR5sSSS5 $!,(df  g=f![4R6a gf=f) r1TrrrrrrN)rr'rrrrrrrr&rrrr rrprojects_locations_workerpoolsrrrrrrrr6r5rr) rhrrrrrrrr r s r9rF#ServerlessOperations.WaitWorkerPool$s7##H$$,,00$0?G G9K ~\,P ^^ - -?.F   ! !,"="= >//  LL 7 7 LL 6 6  ((8 ++I,>,>?))(*=*=wG))%1E1EF ? > >  + + s1.$E.CE E. E+'E.+E..FFcURnU(a[R"X25nUR5nUR UR 5UU(aSOSS9n[ R"[R5 URRRU5nSSS5 [R"WU5$[RRURUR 5n UR"U lUR'5R5n [R"X5n UR)U R 5U U(aSOSS9n [ R"[R*5 URRR-U 5n SSS5 [R"W U5$!,(df  GN0=f!,(df  N7=f![.R0a4n [2R4"[6R8"U 55 Sn A gSn A f[.R:an [<R>"U 5n[AURBS5(aSURBRD;aUeSn[FRH"URJ5nURLU;aJUVs/sHnSROU5PM Os snfnnUS ROS RQU55- n[6RR"U5eSn A f[.R8a n [2R4"U 5 Sn A gSn A ff=f) zUpdate or create worker pool.rQN) workerPoolrfrR)rOrrRrSrTrUrYrZrW)*rr_r`r0RunNamespacesWorkerpoolsReplaceWorkerPoolRequestrbr&rrUPDATE_WORKER_POOLrr4rIr5r6rerrDrfrf%RunNamespacesWorkerpoolsCreateRequestCREATE_WORKER_POOLrirrjr rkrrlrrmrnrrorSrrtrrrrYru)rhr7rrr{rworker_pool_nameworker_pool_update_reqr~new_worker_poolrworker_pool_create_reqraw_worker_poolrrrrrrs r9rE.ServerlessOperations._UpdateOrCreateWorkerPool<s##H< (44  +779  E E&..0%!(d F   # #L$C$C DLL77II$ 'E))'8<<*4488 LL/66  /<< '')668,88  "*!O!O&..0#5"P"   # #L$C$C D LL??FF$ /E))/8DD1E D(E D  - -=.88;<<  + +C%33A6j *$$&6 7 7"j&8&8&G&GG6i"..t?k [ (-89[6==#[99 '(.vdii.@'A  " 7 7 BB  # #suA9G9&G-G9 CG9&G(7G9 G% G9( G62G99M) *H<<M)BL2K21AL22M) M$$M)c ## URnURUR5S9nU(aX&l[R "UR RUUUSSSS9Hn[R"Xu5v M g![Ra n[R"U5 SnAgSnAff=f7f)aList all executions for the given job. Executions list gets sorted by job name, creation timestamp, and completion timestamp. Args: namespace_ref: Resource, namespace to list executions in label_selector: Optional[string], extra label selector to filter executions limit: Optional[int], max number of executions to list. page_size: Optional[int], number of executions to fetch at a time Yields: Executions for the given surface r continue_rr[limitrrr] batch_sizecurrent_token_attributenext_token_attributebatch_size_attributeN)r"RunNamespacesExecutionsListRequestrr6r YieldFromListrnamespaces_executionsr Executionrrrr rhrlabel_selectorr] page_sizerrresultrs r9ListExecutions#ServerlessOperations.ListExecutionss$##H99))+:G, =,,,,44"-8&&!!&33  4 4=99!<<=s/7B?A BB?B<B72B?7B<<B?c ## URnURUR5S9n/nUb-URSR [ R US95 Ub>SR [ RSRU5S9n URU 5 U(aSRU5Ul [R"URRUUUSS S S 9Hn [ R"X5v M g![R a n ["R$"U 5 Sn A gSn A ff=f7f) aList all tasks for the given execution. Args: namespace_ref: Resource, namespace to list tasks in execution_name: str, The execution for which to list tasks. include_states: List[str], states of tasks to include in the list. limit: Optional[int], max number of tasks to list. page_size: Optional[int], number of tasks to fetch at a time Yields: Executions for the given surface rNz{label} = {name})labelrfz{label} in ({states}),)rnstatesr[r\r]r^)rRunNamespacesTasksListRequestrrLrrEXECUTION_LABEL STATE_LABELrYr6r rdrnamespaces_tasksTaskrrrr) rhrexecution_nameinclude_statesr]rirrlabel_selectorsstatus_selectorrjrs r9 ListTasksServerlessOperations.ListTaskss3(##H44))+5GO!  # #((~ $  !/66  .)A7o_-!hh7g =,,,,//"-8&&ii))  4 4=99!<<=s1B:E=A D E D?D:5E:D??Ec #z# URnURUR5S9nUbX&l[R "UR RUUUSSSS9Hn[R"Xu5v M g![Ra n[R"U5 SnAgSnAff=f7f)aList all revisions for the given service. Revision list gets sorted by service name and creation timestamp. Args: namespace_ref: Resource, namespace to list revisions in label_selector: str, label selector for either a service or worker pool for which to list revisions. limit: Optional[int], max number of revisions to list. page_size: Optional[int], number of revisions to fetch at a time Yields: Revisions for the given surface rNr[r\r]r^)rr7rr6r rdrrrrrrrrrgs r9 ListRevisions"ServerlessOperations.ListRevisionss"##H88))+9G!- =,,,,33"-8&&11  4 4=99!<<=s/3B;A BB;B8B3.B;3B88B;cURnURUR5S9n[R"[ R 5 URRRU5nSSS5 WRVs/sHn[R"XR5PM sn$!,(df  N?=fs snf)zList all domain mappings. Args: namespace_ref: Resource, namespace to list domain mappings in. Returns: A list of domain mappings. rN) r&RunNamespacesDomainmappingsListRequestrr&rrLIST_DOMAIN_MAPPINGSrnamespaces_domainmappingsrrr DomainMappingrs r9ListDomainMappings'ServerlessOperations.ListDomainMappingss##H==))+>G    A A B77<R@"U5U5n SSS5 W RBRES5n Sn U (aU RES5(aU Sn U RF(dsU RHS[RJ:Xa3[.RL"SR3UR5555e[.R0"U =(d S 5eU (a[NRPRSU 5 U sSSS5 $![*R,a4 [.R0"SR3UR5555ef=f!,(df  GNN=f!,(df  O=f[R"W U5$) aRCreate a domain mapping. Args: domain_mapping_ref: Resource, domainmapping resource. service_name: str, the service to which to map domain. config_changes: list of ConfigChanger to modify the domainmapping with force_override: bool, override an existing mapping of this domain. Returns: A domain_mapping.DomainMapping object. ) domainMappingrz5Domain mapping to [{}] already exists in this region.z Creating...NReadyr\reasonz3Domain mapping to [{}] is already in use elsewhere.z Could not create domain mapping.)*rr rrerrdomainmappingsIdrf route_nameforce_overriderj(RunNamespacesDomainmappingsCreateRequestrbrfrr&rrCREATE_DOMAIN_MAPPINGrrirHttpConflictErrorrDomainMappingCreationErrorrNamer)ProgressTrackerrrr !DomainMappingResourceRecordPollerrrArecordsready_condition'MAPPING_ALREADY_EXISTS_CONDITION_REASONDomainMappingAlreadyExistsErrorr%rEPrint) rhdomain_mapping_refr)rrr new_mapping config_changerrmappingreadyr\s r9CreateDomainMapping(ServerlessOperations.CreateDomainMappingsI&##H ..22 (55K*::K)!/' !((5k(??!))+!((*779@G    B B C <<99@@I  + +M :&&  8 8 >   ;   $$W-eg 599Y'' " __  # #H -EE F&EECJJ$))+  $>>  99    ! E D C - - #>> C J J"'')     ; : D CH  ' '( ;;s>J%H;=J,J?C2J;AJJ J J J&cURnURUR5S9n[R"[ R 5 URRRU5 SSS5 g!,(df  g=f)zXDelete a domain mapping. Args: domain_mapping_ref: Resource, domainmapping resource. rN) r(RunNamespacesDomainmappingsDeleteRequestrr&rrDELETE_DOMAIN_MAPPINGrrr')rhrrrs r9DeleteDomainMapping(ServerlessOperations.DeleteDomainMapping`sl ##H??  , , .@G    B B C ll,,33G< D C Cs &A== B cHURnURUR5S9n[R"[ R 5 URRRU5nSSS5 [R"WU5$!,(df  N%=f)zGet a domain mapping. Args: domain_mapping_ref: Resource, domainmapping resource. Returns: A domain_mapping.DomainMapping object. rN) r%RunNamespacesDomainmappingsGetRequestrr&rrGET_DOMAIN_MAPPINGrrrr r)rhrrrrs r9GetDomainMapping%ServerlessOperations.GetDomainMappingns##H<<  , , .=G    ? ? @77;;GDh A  ' '( ;; A @s &B B!c dUc-[R"[R"USLU SLS9SSS9nUbL[R "UUUUU UU UR U5 un n U cgUR[U 55 U (+nU(aURXXE5$URXXE5$)aDeploy to create a new Cloud Run Job or to update an existing one. Args: job_ref: Resource, the job to create or update. config_changes: list, objects that implement Adjust(). release_track: ReleaseTrack, the release track of a command calling this. tracker: StagedProgressTracker, to report on the progress of releasing. asyn: bool, if True, return without waiting for the job to be updated. build_image: The build image reference to the build. build_pack: The build pack reference to the build. build_source: The build source reference to the build. repo_to_create: Optional googlecloudsdk.command_lib.artifacts.docker_util.DockerRepo defining a repository to be created. prefetch: the job, pre-fetched for DeployJob. `None` indicates a nonexistent job so the job has to be created, else this is for an update. already_activated_services: bool. If true, skip activation prompts for services Returns: A job.Job object. N)rrTrr) r)rr" JobStagesr#rrrLr CreateJob UpdateJob)rhjob_refrrrrrrrrrrrrV is_creates r9 DeployJobServerlessOperations.DeployJobsJ ::   (4"0"< # g!)!5!5       $ ,,  "lAq!Q  3LAB I ^^GW CC ^^GW CCr8cXURn[RRURUR 5R 55nUR 5UlUR 5R5nUHnURU5nM URUR5US9n Sn [R"[R5 [R"URR R#U 5U5n SSS5 U(dX[6R8"UR:U5n [<R>"X5n URAU 5 U RC5n U $![$R&a4 [(R*"SR-UR 555e[$R.a4n [0R2"[(R4"U 55 Sn A NSn A ff=f!,(df  GN=f)a5Create a new Cloud Run Job. Args: job_ref: Resource, the job to create. config_changes: list, objects that implement Adjust(). tracker: StagedProgressTracker, to report on the progress of releasing. asyn: bool, if True, return without waiting for the job to be updated. Returns: A job.Job object. )rrNzJob [{}] already exists.)"rrJobrerrfrrfrrjRunNamespacesJobsCreateRequestrbr&rr CREATE_JOBnamespaces_jobsrirrrrurrjr rkrlr<r=GetJobr ConditionPollerrr)rhrrrrrnew_jobrrcreate_request created_jobrrrs r9rServerlessOperations.CreateJobs##Hggkk$,,(8(=(=(?@G<<>GL ^^  * * ,F' $$W-g(<< OO f=NK    7 7 8 ?gg LL ( ( / / ?  9   g6f))&:f F#&&(k  - - #99 & - -glln =   / /?0::1=>>? 9 8s1$H&:F  AH#*H HHH H)cURnURU5nUc3[R"SR UR 555eUHnUR U5nM URUR5UR5S9nSn [R"[R5 [R"UR R"R%U5U5n SSS5 U(dX[0R2"URU5n [4R6"X5n UR9U 5 U R;5n U $![&R(a4n [*R,"[R."U 55 Sn A NSn A ff=f!,(df  N=f)a:Update an existing Cloud Run Job. Args: job_ref: Resource, the job to update. config_changes: list, objects that implement Adjust(). tracker: StagedProgressTracker, to report on the progress of updating. asyn: bool, if True, return without waiting for the job to be updated. Returns: A job.Job object. NJob [{}] could not be found.)rrf)rrrJobNotFoundErrorrrrj"RunNamespacesJobsReplaceJobRequestrbrr&rr UPDATE_JOBrrrr ReplaceJobrrjr rkrlr<r=r rrr) rhrrrrr update_jobrreplace_request returned_jobrrrs r9rServerlessOperations.UpdateJobsk##HW%J ! 2 2 ( / /  ? (  '' 3j(AA    w';';'=BOL    7 7 8?ww LL ( ( 3 3O Dh  9   g6f))&:f F#'')l  / /?0::1=>>? 9 8s0F0:E%%F-9*F(#F0(F--F00 F>cURnUR5nU(aXhlURUR 5US9n [ R "[R5 URRRU 5n SSS5 U(a["R$"W U5$UR&R)W R*R,SU R*R.0SS9n [0R2"UR4U 5n U(a["R6O["R8nUR5U 5n[:R<"UR>SS 9HnURAU5 M [BRD"U UU[FRH"5S 9nURKUU(aSOS 5 UR5U 5$![Ra-n U RS:Xa[R "S5eU eSn A ff=f!,(df  GN=f![RLa. [RL"S [NRP"X_5-5ef=f) aRun a Cloud Run Job, creating an Execution. Args: job_ref: Resource, the job to run tracker: StagedProgressTracker, to report on the progress of running wait: boolean, True to wait until the job is complete asyn: bool, if True, return without waiting for anything release_track: ReleaseTrack, the release track of a command calling this overrides: ExecutionOverrides to be applied for this run of a job Returns: An Execution Resource in its state when RunJob returns. )rf runJobRequestizResource exhausted error. This may mean that too many executions are already running. Please wait until one completes before creating a new one.Nrzrun.namespaces.executionsrT) ignore_retry)rrzThe execution failed.))r RunJobRequest overridesRunNamespacesJobsRunRequestrr&rrRUN_JOBrrRunrrlr*rrurrfrrrrfr>r<r= GetExecutionCOMPLETED_CONDITIONSTARTED_CONDITIONrrrrr ExecutionConditionPollerr"ExecutionDependenciesrExecutionFailedErrorrGetExecutionCreatedMessage)rhrrwaitrrrrrun_job_request run_requestexecution_messager execution_refrterminal_conditionexrrs r9RunJobServerlessOperations.RunJobs0,##H,,.O"+66  ! ! #?7K    4 4 5  LL88<<[I 6  !2H ==NN((""'' 1 : : D DE.)M   t00- @F)- %%93N3N   = )B33 D 0 0113 F  FDDa8   ] ++M % % ==C %;;5   6 5H ! 5 5 ! 6 6 !  4 4] G H s7,H*.%G&:H<&H':(H""H''H** H9cURnURUR5S9n[R"[ R 5 URRRU5n[R"XB5sSSS5 $!,(df  g=f![Ra n[R"U5 SnAgSnAf[R a gf=f)z8Return the relevant Job from the server, or None if 404.rN)rRunNamespacesJobsGetRequestrr&rrGET_JOBrrrrrrrrrr)rhrr get_request job_responsers r9rServerlessOperations.GetJob^s##H66  ! ! #7K  ! !,"6"6 7||3377 D ww|. 8 7 7  4 4=99!<<  + + rcURnURUR5S9n[R"[ R 5 URRRU5n[R"XB5sSSS5 $!,(df  g=f![Ra n[R"U5 SnAgSnAf[R a gf=f)z9Return the relevant Task from the server, or None if 404.rN)rRunNamespacesTasksGetRequestrr&rrGET_TASKrrtrrrurrrrr)rhtask_refrr task_responsers r9GetTaskServerlessOperations.GetTaskns##H77  " " $8K  ! !,"7"7 8 5599+F yy1 9 8 8  4 4=99!<<  + + rcURnURUR5S9n[R"[ R 5 URRRU5n[R"XB5sSSS5 $!,(df  g=f![Ra n[R"U5 SnAgSnAf[R a gf=f)z>Return the relevant Execution from the server, or None if 404.rN)r!RunNamespacesExecutionsGetRequestrr&rr GET_EXECUTIONrrerrrfrrrrr)rhrrrexecution_responsers r9r!ServerlessOperations.GetExecution~s##H<<  ' ' )=K  ! !,"<"< =!\\??CCKP""#5@ > = =  4 4=99!<<  + + rcURnURUR5S9n[R"[ R 5 URRRU5nURVs/sHn[R"XR5PM snsSSS5 $s snf!,(df  g=f![Ra n[R "U5 SnAgSnAff=f)z"Returns all jobs in the namespace.rN)rRunNamespacesJobsListRequestrr&rr LIST_JOBSrrrrrrrrrrrs r9ListJobsServerlessOperations.ListJobss##H33))+4G=  ! !,"8"8 9<<//44W=4CCC9C44C9cURnURUR5S9n[R"[ R 5 URRRU5 SSS5 g!,(df  g=f![Ra4 [R"SRUR555ef=f)zDelete the provided Job. Args: job_ref: Resource, a reference to the Job to delete Raises: JobNotFoundError: if provided job is not found. rNr)rRunNamespacesJobsDeleteRequestrr&rr DELETE_JOBrrr'rrrrrr)rhrrrs r9 DeleteJobServerlessOperations.DeleteJobs##H55  ! ! #6G  ! !,"9"9 : $$++G4 ; : :  + + ! 2 2 ( / /  ? *$B&A>5B> B B BACcURnURUR5S9n[R"[ R 5 URRRU5 SSS5 g!,(df  g=f![Ra4 [R"SRUR555ef=f)zDelete the provided Execution. Args: execution_ref: Resource, a reference to the Execution to delete Raises: ExecutionNotFoundError: if provided Execution is not found. rN"Execution [{}] could not be found.)r$RunNamespacesExecutionsDeleteRequestrr&rrDELETE_EXECUTIONrrer'rrrExecutionNotFoundErrorrrrhrrrs r9DeleteExecution$ServerlessOperations.DeleteExecution##H;;  ' ' )<G  ! !,"?"? @ **11': A @ @  + + ! 8 8 . 5 5m6H6H6J K rcURnURUR5S9n[R"[ R 5 URRRU5 SSS5 g!,(df  g=f![Ra4 [R"SRUR555ef=f)zCancel the provided Execution. Args: execution_ref: Resource, a reference to the Execution to cancel Raises: ExecutionNotFoundError: if provided Execution is not found. rNr)r$RunNamespacesExecutionsCancelRequestrr&rrCANCEL_EXECUTIONrreCancelrrrrrrrs r9CancelExecution$ServerlessOperations.CancelExecutionrrcURnUR[R"U5S9nURR R U5nU$)z$Gets the IAM policy for the service.)ri)r/RunProjectsLocationsServicesGetIamPolicyRequestsix text_typerr GetIamPolicy)rhr)rrrs r9 _GetIamPolicy"ServerlessOperations._GetIamPolicysP##HFF|,GG::GGPH Or8cURnU=(d URn[R"X5nUR U5n U(adU(a]U(a#[ R "URXU5 O3[ R"XU5(a[ R"XU5 UR[R"U5URU S9S9n URRR!U 5n U $)aAdd or remove the given IAM policy binding to the provided service. If no members or role are provided, set the IAM policy to the current IAM policy. This is useful for checking whether the authenticated user has the appropriate permissions for setting policies. Args: service_ref: str, The service to which to add the IAM policy. add_binding: bool, Whether to add to or remove from the IAM policy. member: str, One of the users for which the binding applies. role: str, The role to grant the provided members. region_override: str, The region to use instead of the configured region. Returns: A google.iam.v1.TestIamPermissionsResponse. )policy)risetIamPolicyRequest)rrr!K8sToOnePlatformrrAddBindingToIamPolicyBindingBindingInPolicyRemoveBindingFromIamPolicy/RunProjectsLocationsServicesSetIamPolicyRequestr rSetIamPolicyRequestrr SetIamPolicy) rhr add_bindingr'rolerrroneplatform_servicerrrjs r9r0ServerlessOperations.AddOrRemoveIamPolicyBindings0##H  , F2CC   3 4F $ &&x'7'7N  # #FD 9 9++FDAFF23$888GGG__ 8 8 E Eg NF Mr8cURnU=(d URn[R"X5nUR [ R "U5UR[S9S9nURRRU5n[[5R[UR55$)zBCheck if user has permission to set the iam policy on the service.) permissions)ritestIamPermissionsRequest)rrr!r5RunProjectsLocationsServicesTestIamPermissionsRequestr rTestIamPermissionsRequestNEEDED_IAM_PERMISSIONSrrTestIamPermissionssetissubsetr")rhrrrrrrrs r9CanSetIamPolicyBinding+ServerlessOperations.CanSetIamPolicyBindings##H  , F2CCLL23"*"D"D.#E# MG ||77JJH % & / /H4H4H0I JJr8cURU5n[[5nURU5 UR XSUSS9 UR 5 g)z:Validates starting service operation with provided config.T)rzrMr{N)rrFAKE_IMAGE_DIGESTrLrpop)rhrrrMfake_validation_images r9_ValidateService%ServerlessOperations._ValidateService sU ??; 'D34EF/0t$ r8cUR[R"[R55 UR[R"[R 55 UR[R"[R 55 UR[R"[R55 g)zCClear run functions annotations to the service before setting them.N)rLr_DeleteAnnotationChanger3RUN_FUNCTIONS_SOURCE_LOCATION_ANNOTATION_DEPRECATED3RUN_FUNCTIONS_FUNCTION_TARGET_ANNOTATION_DEPRECATED-RUN_FUNCTIONS_IMAGE_URI_ANNOTATION_DEPRECATED1RUN_FUNCTIONS_ENABLE_AUTOMATIC_UPDATES_DEPRECATED)rhrs r9r2ServerlessOperations._ClearRunFunctionsAnnotations*s11  G G  11  G G  11  A A  11  E E r8rc U(a[R"U5OSn URU5nSnU(a[R"U5nU(aUSR S5OUn[ RU[ RU[ RU [ RU[ RU [ RU[ RU[ RU[ RU (aSOS0 nU (aUR!UU U 5 OUR#X5 UR%SUR'555 U (a5UR)[*R,"[ R.U 55 gUR)[*R0"[ R.55 g)z-Add run functions annotations to the service.Nrrtruefalsec3\# UH"upUcM [R"X5v M$ g7frP)r_SetAnnotationChange)rUkvs r9rWCServerlessOperations._AddRunFunctionsAnnotations..ps-+DA  5..q44+s ,,)jsondumpsrr$rrAr.RUN_FUNCTIONS_BUILD_SERVICE_ACCOUNT_ANNOTATION*RUN_FUNCTIONS_BUILD_WORKER_POOL_ANNOTATION'RUN_FUNCTIONS_BUILD_ENV_VARS_ANNOTATION!RUN_FUNCTIONS_BUILD_ID_ANNOTATION#RUN_FUNCTIONS_BUILD_NAME_ANNOTATION(RUN_FUNCTIONS_BUILD_IMAGE_URI_ANNOTATION.RUN_FUNCTIONS_BUILD_SOURCE_LOCATION_ANNOTATION.RUN_FUNCTIONS_BUILD_FUNCTION_TARGET_ANNOTATION,RUN_FUNCTIONS_BUILD_ENABLE_AUTOMATIC_UPDATESrrextendrrLr_r=RUN_FUNCTIONS_BUILD_BASE_IMAGEr3)rhrrrrrrrrrrrrbuild_env_vars_strfunction_targetr image_uriannotations_maps r9r0ServerlessOperations._AddRunFunctionsAnnotationsAsq 8FN34:::FOK((9k.8 1 !!'*kI>>::K779K11833Z88)>> >><<.FG O  !!   *  -- #))+   0 0446F    3 344 r8cZURU5nUHnURU5nM g)aApply config changes to Job resource to validate. This is to replicate the same validation logic in `jobs/services update`. Override attempts with types (out of string literals, secrets, config maps) that are different from currently set value type will appear as errors in the console. Args: job_ref: Resource, job resource. config_changes: Job configuration changes from Overrides N)rrj)rhrrrun_jobchanges r9ValidateConfigOverrides,ServerlessOperations.ValidateConfigOverridess*kk'"G  g&g!r8c URRUUUURRRUR55S9$)N)containerOverrides taskCounttimeoutSeconds priorityTier)r OverridesPriorityTierValueValuesEnumupper)rhtasks task_timeout priority_tiercontainer_overridess r9GetExecutionOverrides*ServerlessOperations.GetExecutionOverridessQ    ) ).#))33OO    ! * r8cjURRUU=(d /URU5US9$)N)rfargsenv clearArgs)rContainerOverride_GetEnvVarList)rhrfupdate_env_varsrg clear_argss r9MakeContainerOverride*ServerlessOperations.MakeContainerOverrides;    1 1  ZR    0 2 r8c/nUbAUR5H-up4URURRX4S95 M/ U$)N)rfvalue)rrLrEnvVar)rhenv_vars env_var_listrfrqs r9rk#ServerlessOperations._GetEnvVarListsHL!)+$D0077T7OP* r8)rrrrr)rF)NFNNFFNNNNNFFFFNNrNNNNFFNNNF)rNNd)NNrw)Nrw)NFNNNNNF)NF)NFFNN)TNNNrP)Tr3r4r5r6rmrpropertyrrrrrrrrrrGAr rr!r+r3r8rIrNrrrrrrr)StagedProgressTrackerrSrrrr_ ConfigChangerboolrr rrr$rr+RetryOnExceptionr)r:r@rIrFrErkrzr}rrrrrrrrrrrrrrr rrr*r0rrrVrdrnrkr7r2r8r9rErEsP&$ ( (*< = =D&6:5F5F5I5I+Z80.( =N`DCHm^+ZI*35533 3 -;;< 3  3L  !& (*$?B B&PV$( T rI>? $ ==~0EPEH$=T  2=jBE&=P0 Frs"N&%'  %9'A4505*3/,.+E,5H.(3ON895C1A@*#'*)8G*   %/"#6 56N j&& 22j d#0FF$$ 2 F F$  d# .DD $  d# 0FF $ Y6Yr8