H SrSSKJr SSKJr SSKJr SSKJr SSKrSSKJr SSKJ r SSK r SS K J r SS K Jr SSKJ r SS KJr SS KJr SS KJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK!r!Sr"Sr#Sr$Sr%Sr&\RNRPS\RNRRS\RNRTS0r+Sr,Sr-Sr.Sr/Sr0Sr1Sr2\/\0\1\24r3Sr4S r5S!r6S"r7S#r8\ R"\5\/\6\0\7\1\8\205r9S$r:\.\4\:4r;"S%S&\Rx5r=S'r>S(r?S)r@S*rAS+rBS,rCS-rDS.rES/rFS0rGS1rHS2rIS3rJS;S4jrKS5rLS6rMS>  3 33  / //r(cU[R"[[5La UR$U[R"[[ 5La UR $UR$)zHReturns corresponding GoogleCloudFunctionsV2(alpha|beta|ga)stateMessage.)r r4r5r;'GoogleCloudFunctionsV2alphaStateMessager=&GoogleCloudFunctionsV2betaStateMessage"GoogleCloudFunctionsV2StateMessager@s r)GetStateMessagerGsP '' 9==  ; ;;4)))X>>  : ::  6 66r(c[RRRS5R 5$![R a gf=f)z9Returns the API endpoint override property value for GCF.rN)rr,api_endpoint_overridesPropertyr/NoSuchPropertyErrorrr(r)GetApiEndpointOverriderLsJ    3 3 < <  ce   ' ' s69AAcb[RU5n[R"[U5$)z Returns an API client for GCFv2.)r2r3r GetClientInstancer5r6s r)rNrNr9r(c[SU5$)zAReturns the list of string representations of the state messages.c`SR[UR5UR5$)Nz[{}] {})formatstrseveritymessage)sts r))GetStateMessagesStrings..s!!#bkk"2BJJ?r()map)state_messagess r)GetStateMessagesStringsrZs ? r(c,U[R"[[5La UR$U[R"[[ 5La UR $U[R"[[5La UR$[S5e)zMReturns corresponding GoogleCloudFunctionsV2(alpha|beta|ga)OperationMetadata.zInvalid messages module.) r r4r5r;,GoogleCloudFunctionsV2alphaOperationMetadatar=+GoogleCloudFunctionsV2betaOperationMetadata_V2_GA'GoogleCloudFunctionsV2OperationMetadataNotImplementedErrorr@s r)GetOperationMetadatarasq '' 9==  @ @@4)))X>>  ? ??4)))V<<  ; ;; 8 99r(c~[R"[U5[R"UR55$N)rPyValueToMessageraMessageToPyValuemetadata)rA operations r)_GetOperationMetadatarhs1  " "8$ 2 23 r(cSR[R"U5RSS5R 55$)zGConverts NameValueValuesEnum into the header to use in progress stages.z[{}]_ )rQsix text_typereplacetitle) name_enums r)_GetStageHeaderrqs0 s}}Y/77SAGGI JJr(cURRU5$![Ra=nUR[ R RR:XaSnAgeSnAff=f)z/Get operation and return None if doesn't exist.N) projects_locations_operationsr/apitools_exceptions HttpError status_coderlmoves http_client NOT_FOUND)clientrequesterrors r) _GetOperationr}sX  / / 3 3G <<  & &  CII11;;;   sA.2A)(A))A.c [X5nUR(a [R"UR5e/nUR(as[ X#5nUR HXnUR[R"[UR5[R"UR5S95 MZ X44$)z$Returns the stages in the operation.)key)r}r|rStatusToFunctionsErrorrfrhstagesappendrStagerqnamerlrm)rzr{rArgroperation_metadatastages r)_GetOperationAndStagesrsF,)__  + +IOO << &.xC#** mm  ejj)s}}UZZ/H +  r(ctURRU5nUR(a2[R"UR[ UR5S9e[ X45nURGHnUR[U5RRLnUR[U5RRLnU(d U(dMj[UR5n URU 5(aMUR!U 5(aUR#U 5 UR$=(d Sn U(aU =(d SS-n OSn UR&(a$U S:XaU SR)UR&5- n UR+X5 U(dGM;UR,(a(UR/U [1UR,55 GMtUR3U 5 GM UR4(a'UR6(a[8R:"S5 U$)z?Returns a Boolean indicating whether the request has completed.) error_messagez In progressz... BUILDzLogs are available at [{}]aA custom IAM role was detected. If this role is used to manage or access your function, you must manually add the equivalent Cloud Run permissions and add the binding to your Cloud Run function. Refer to https://cloud.google.com/run/docs/reference/iam/permissions for details.)rsr/r|rrOperationErrorToStringrhrstaterBStateValueValuesEnum IN_PROGRESSCOMPLETErRr IsComplete IsWaiting StartStagerT resourceUrirQ UpdateStage stateMessagesCompleteStageWithWarningsrZ CompleteStagedonecustomIamRoleDetectedrwarning) rzr{trackerrArgrrstage_in_progressstage_complete stage_key stage_messages r)_GetOperationAndLogProgressrs2266w?)__  + +'=ioo'N -XA!((e x)>>JJJ  x)>>GGG ^EJJI)$$## #MM'RM$5 ?mm Y'13::5;L;LMMm  1~   )) .u/B/BC  i(O)T^^*@@KK  r(chSnURURS9n[R"S[S9n[ R "[S9nUR[XU/U[S9up)SSS5 UbW U- n US - n[R"UW [S9nUR (aU (d UsSSS5 $[ R "[S9nUR["XXq/S [S9nSSS5 U$![ Ra0 [R"SRUR55ef=f!,(df  N=f![ Ra0 [R"SRUR55ef=f!,(df  U$=f) aWait for a long-running operation (LRO) to complete. Args: client: The GCFv2 API client. messages: The GCFv2 message stubs. operation: The operation message response. description: str, the description of the waited operation. extra_stages: List[progress_tracker.Stage]|None, list of optional stages for the progress tracker to watch. The GCF 2nd api returns unexpected stages in the case of rollbacks. Returns: cloudfunctions_v2_messages.Operation, the finished operation. cHUup#U(+=(a UR(+$rcr)resrjoprs r)IsNotDoneAndIsMissingStages5WaitForOperation..IsNotDoneAndIsMissingStages1sJB: %bgg+%r()rzPreparing function)aborted_message) max_wait_ms)argsshould_retry_ifsleep_msz Operation {0} is taking too longNz...c$UR(+$rcr)rrjs r)rV"WaitForOperation..\s BGG r()3CloudfunctionsProjectsLocationsOperationsGetRequestrrProgressTracker_DEFAULT_ABORTED_MESSAGErRetryer MAX_WAIT_MS RetryOnResultrSLEEP_MS WaitExceptionrFunctionsErrorrQStagedProgressTrackerrr) rzrArg description extra_stagesrr{rretryerrs r)WaitForOperationrs$&  H H >> I ''',Dmm 4G !// *5 0i " lF+--6+C~~f  mm 4G '' %33 (i( ?     % % , 3 3INN C L     % % , 3 3GLL A ( sCE DF"F"EAEE  EAFF"" F1cSRUR[R"UR55n[ R "S[5nUR(auURHen[R"UR[R"U55nURcURcMTUS[U5-- nMg U$)zReturns a human readable string representation from the operation. Args: error: A string representing the raw json of the operation error. Returns: A human readable string representation of the error. z%OperationError: code={0}, message={1}r )rQcodeencoderDecoderTr r4r;detailsrrdStatusrer)r|rrAdetail sub_errors r)rrgs:@@ jj'../- # #$4i @( ]]--++ //844V<i  #y'8'8'D 6y AAA  r(cF^^[UU4SjUR55$)zReturns whether the given SA has the given role bound in given policy. Args: iam_policy: The IAM policy to check. sa_email: The service account to check. role: The role to check for. c3># UH9nSRT5UR;=(a URT:Hv M; g7f)serviceAccount:{}N)rQmembersrole).0brsa_emails r) !HasRoleBinding..s< "!  *aii7JAFFdNJ"sAA)anybindings) iam_policyrrs ``r)HasRoleBindingr~s%  ""  r(c^^U=(d /n[R"[55nSRT5n[R "U5m[ UU4SjU/UQ55(ag[RRSRTX55 [R"5=(a$ [R"SRUT5S9nU(d[R"S5 g[R"XEU5 [RRS5 g![R a [R"S UTU5 gf=f) aPrompts to bind the role to the service account in project level if missing. If the console cannot prompt, a warning is logged instead. Args: sa_email: The service account email to bind the role to. role: The role to bind if missing. alt_roles: Alternative roles to check that dismiss the need to bind the specified role. reason: Extra information to print explaining why the binding is necessary. rc3>># UHn[TTU5v M g7frc)r)rrrrs r)r,PromptToBindRoleIfMissing..s O*h 2 2.sL/K**/KsznSome Data Access audit logs are disabled for [{}]: https://console.cloud.google.com/iam-admin/audit?project={}z, Enable all Data Access audit logs for [{}]?rrr) update_maskz,Data Access audit logs successfully enabled.zkYou do not have permission to update the IAM policy and ensure Data Access audit logs are enabled for [{}].)r0r rrQr rrtrrrrsetr _LOG_TYPESrrrrrextendrAuditLogConfig SetIamPolicy) rr.r warning_msgpolicyrenabled_log_typesltlog_types_to_enables r)!PromptToEnableDataAccessAuditLogsrs L'**73+&&,fWo   & &{ 3F$F4,L|/K/KLL*$ **DDJF E     KK  **;  " "CJJ    '1Pj>O4OjP%%9LM9L2|""2".9LMk~NJJCDU  / / KK CCI6 D    FQM  / /KK 3396'?s5F2* G17G1G6=4G;29G.-G.;9H76H7c[5nUc[R$SU;a[R$SU;a[R$SU;a[R $[R$)z=Determine the cloudfunctions API env the gcloud cmd is using.ztest-cloudfunctionszautopush-cloudfunctionszstaging-cloudfunctions)rLrr&r#r$r%) api_strings r)GetCloudFunctionsApiEnvr,sZ%'* ;;j( ;;*, ??+ >> r(rc)Nr)[__doc__ __future__rrrrenumapitools.base.pyrrrt frozendict+googlecloudsdk.api_lib.cloudresourcemanagerr r projects_api_util#googlecloudsdk.api_lib.functions.v2googlecloudsdk.api_lib.utilr googlecloudsdk.callioper calliope_base#googlecloudsdk.command_lib.projectsr googlecloudsdk.corerrgooglecloudsdk.core.consolerrgooglecloudsdk.core.utilrrrlr5r;r=r^r ReleaseTrackALPHABETAGAr2rrEA_PUBSUB_MESSAGE_PUBLISHEDEA_STORAGE_ARCHIVEEA_STORAGE_DELETEEA_STORAGE_FINALIZEEA_STORAGE_UPDATEEVENTARC_STORAGE_TYPESEF_PUBSUB_MESSAGE_PUBLISHEF_STORAGE_ARCHIVEEF_STORAGE_DELETEEF_STORAGE_FINALIZEEF_STORAGE_METADATA_UPDATE!EVENTFLOW_TO_EVENTARC_STORAGE_MAPLEGACY_PUBSUB_MESSAGE_PUBLISHPUBSUB_MESSAGE_PUBLISH_TYPESEnumrr0r4rBrGrLrNrZrarhrqr}rrrrrr GetMessagesr frozensetrLogTypeValueValuesEnum ADMIN_READ DATA_READ DATA_WRITErrrrrr(r)r/s2?&%' %>DZ:,9E#*288*    L $$i##X!!4   N><@D :426C$.$9$9*(, 1 ;%!6  !  TYY ;8 078  :K  (>D<@EP.&0f!,,. 66AA66@@66AA 6AH r(