<SrSSKJr SSKJr SSKJr SSKrSSKJr SSKJ r SSK J r SS K J r SS K Jr SS K Jr SS KJr S r\S-r\S-rSrSrSrSrSrSrSrSrg)z,Common helper methods for Services commands.)absolute_import)division)unicode_literalsN)encoding) exceptions) apis_internal)log) properties) transport)retryzgcloud services operations z describe {0}zwait {0}zservicemanagement.servicesc0[R"SS5$)Nservicemanagementv1)r_GetMessagesModule4lib/googlecloudsdk/api_lib/services/services_util.pyGetMessagesModuler's  ) )*=t DDrcSSKJn [RRR R 5nUR[RUS9n[R"SSUS9$)zDGet a client instance for service management without resource quota.r) transports)response_encodingenable_resource_quotarr) http_client) googlecloudsdk.core.credentialsrr VALUESbilling quota_projectIsExplicitlySetGetApitoolsTransportr ENCODINGr_GetClientInstance)rrrs rGetClientInstancer",si9--==?//!**103+  ) )4[ ::rcU(a5[RRRR U5 U$[RRRR SS9nU$)zValidate the project ID, if supplied, otherwise return the default project. Args: project_id: The ID of the project to validate. If None, gcloud's default project's ID will be returned. Returns: The validated project ID. T)required)r rcoreprojectValidateGet) project_ids rGetValidatedProjectr*@s\""++J7 ""''//33T3BJ rc^U4Sjn/n[R"SSSS9RX U/SSS9 U(aUS $S $![Ra& [R "S R U55ef=f) aHWait till the operation is done. Args: name: The name of operation. get_op_func: The function that gets the operation. Raises: exceptions.OperationErrorException: when the getting operation API fails. apitools_exceptions.HttpError: Another miscellaneous error with the service. Returns: The result of the operation cz>T"U5nUR(aURU5 UR(+$)N)doneappend)nameresultop get_op_funcs r_CheckOpWaitOperation.._CheckOp`s, T B ww mmBww;rg?i'i@w)exponential_sleep_multiplierwait_ceiling_ms max_wait_msTi)should_retry_ifsleep_mszTTimed out while waiting for operation {0}. Note that the operation is still pending.rN)r Retryer RetryOnResultMaxRetrialsExceptionr TimeoutErrorformat)r/r2r3r0s ` r WaitOperationr?Qs & D MM%("$%2M VndT%2%K &$&  # #D  ! !#66r/errorrOperationErrorExceptionmessagedetailsr1s rPrintOperationrKus JJ<CCBGGLM XX  , ,Krww(("((*:*:; ==**;BB277KLrc UR(d9[RRSR UR 55 gUR (aY[R"SR UR UR RUR R55eUR(am[RRSR UR [R"[R"UR5SSSS955 g[RRS R UR 55 g) zPrint the operation with response. Args: op: The long running operation. Raises: OperationErrorException: if the operation fails. Returns: Nothing. rANrB%Operation [{0}] complete. Result: {1}T,: sort_keysindent separatorsrC)r-r rDrEr>r/rFrrGrHrIresponsejsondumpsr MessageToDictrJs rPrintOperationWithResponserZs JJ<CCBGGLM XX  , ,Krww(("((*:*:; ==[[JJ<CC   " "2;; /!  #$%JJ=DDRWWMNrc UR(d9[RRSR UR 55 gUR (aXUR RnURSS5n[R"SR UR U55eUR(am[RRSR UR [R"[R"UR5SSS S 955 g[RRS R UR 55 g) zPrint the operation with response for update consumer policy. Args: op: The long running operation. Raises: OperationErrorException: if the operation fails. Returns: Nothing. rANzPlease specify forcez,Please specify --bypass-api-usage-check flagz/The operation "{0}" resulted in a failure "{1}"rMTrNrOrRrC)r-r rDrEr>r/rFrHreplacerrGrVrWrXrrY)r1 error_messagemodified_messages r1PrintOperationWithResponseForUpdateConsumerPolicyr_s JJ<CCBGGLM XXHH$$M%,, N  , ,9@@ GG%   [[JJ/66 GG JJ&&r{{3%    JJ=DDRWWMNr)__doc__ __future__rrrrWapitools.base.pyrgooglecloudsdk.api_lib.servicesrgooglecloudsdk.api_lib.utilrgooglecloudsdk.corer r r googlecloudsdk.core.utilr OP_BASE_CMDOP_DESCRIBE_CMD OP_WAIT_CMDSERVICES_COLLECTIONrr"r*r?rKrZr_rrrrkst 3&' %65#*)*, .J& 2E :("!'HM,O>(Or