SrSSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SSK J r \ RR4S jr\ RR"4S jr\ RR4S jr\ RR4S jr\ RR4S jr"SS\ R,5r"SS\ R,5rg)z3Utilities for calling the Metastore Operations API.)absolute_import)division)unicode_literals)util)waiter)base)logc>[R"US9R$)N release_track)api_utilGetClientInstanceprojects_locations_operationsr s 7lib/googlecloudsdk/api_lib/metastore/operations_util.py GetOperationrs  # #! !!"cp[US9R[R"US9R US95$)a4Calls the Metastore Operations.Cancel method. Args: relative_resource_name: str, the relative resource name of the Metastore operation to cancel. release_track: base.ReleaseTrack, the release track of command. Will dictate which Dataproc Metastore client library will be used. Returns: Empty r name)rCancelr GetMessagesModule1MetastoreProjectsLocationsOperationsCancelRequestrelative_resource_namer s rrr!@ M 2 9 9  %99% :  rcp[US9R[R"US9R US95$)a4Calls the Metastore Operations.Delete method. Args: relative_resource_name: str, the relative resource name of the Metastore operation to delete. release_track: base.ReleaseTrack, the release track of command. Will dictate which Dataproc Metastore client library will be used. Returns: Empty r r)rDeleter r1MetastoreProjectsLocationsOperationsDeleteRequestrs rrr6rrcT[R"[US9URUSSS9$)aAWaits for an operation to complete and return it. Polls the operation at least every 15 seconds, showing a progress indicator. Returns when the operation has completed. The timeout periods of this operation is one hour. Args: operation: Operation Message, the operation to poll message: str, a message to display with the progress indicator. For example, 'Waiting for deletion of [some resource]'. release_track: base.ReleaseTrack, the release track of command. Will dictate which Metastore client library will be used. Returns: poller.GetResult(operation). r 6: max_wait_mswait_ceiling_ms)rWaitFor_OperationPollerWithErrorr operationmessager s rPollAndReturnOperationr*Ks-& m<nn   rcV[R"[US9URUSSS9 g)aWaits for an operation to complete. Polls the operation at least every 15 seconds, showing a progress indicator. Returns when the operation has completed. Args: operation: Operation Message, the operation to poll message: str, a message to display with the progress indicator. For example, 'Waiting for deletion of [some resource]'. release_track: base.ReleaseTrack, the release track of command. Will dictate which Metastore client library will be used. r r r!r"N)rr%_OperationPollerrr's rWaitForOperationr-gs( ..]3nn  rc`^\rSrSrSr\R R4U4SjjrSr Sr U=r $)r,}z3Class for polling Metastore longrunning Operations.c>>[[U] [US9S5 g)Nr cU$Nxs r+_OperationPoller.__init__..Qr)superr,__init__rselfr __class__s rr:_OperationPoller.__init__s D*=1;rcUR(dgUR(a5[R"URURR 5eg)NFT)doneerrorr OperationErrorrr))r<r(s rIsDone_OperationPoller.IsDones7 >>   # #INNIOO4K4K LL rr3 __name__ __module__ __qualname____firstlineno____doc__r ReleaseTrackGAr:rC__static_attributes__ __classcell__r=s@rr,r,}s$;#'#4#4#7#7 rr,c`^\rSrSrSr\R R4U4SjjrSr Sr U=r $)r&zDClass for polling Metastore longrunning Operations and print errors.c>>[[U] [US9S5 g)Nr cU$r2r3r4s rr64_OperationPollerWithError.__init__..r8r)r9r&r:rr;s rr:"_OperationPollerWithError.__init__s #T3=1;rc"UR(dgUR(GakURR(a4[RR SURR5 URR (a4[RR SURR 5 URR(aURRSRHjnURS:XdM[RR SURRRSRR5 Ml [R"UR S5eg) NFz Status Code:zError message:rdetailszError details:T)r@rAcoder statusPrintr)rWadditionalPropertieskeyvalue object_value properties string_valuer rBr)r<r(r)s rrC _OperationPollerWithError.IsDones >>     )=)=>   )9??+B+BC   ..q1FFG [[I % JJ    **55a8>>KK G  # #INNB 77 rr3rErOs@rr&r&s$L#'#4#4#7#7 rr&N)rJ __future__rrr googlecloudsdk.api_lib.metastorerr googlecloudsdk.api_lib.utilrgooglecloudsdk.calliopergooglecloudsdk.corer rKrLrALPHArrr*r-CloudOperationPollerNoResourcesr,r&r3rrrjs:&'=.(# $0033" 261B1B1H1H*261B1B1E1E,'+&7&7&:&:88<7H7H7K7K, v==   F Fr