-SrSSKJr SSKJr SSKJr SSKJr SSKJr SSjr SSjr "S S \R5r "S S \ 5rg )z@Utilities for dealing with long-running operations (simple uri).) list_pager)apis)waiter) properties) resourcesc0[R"SU5$)Nml)rGetMessagesModule)versions 2lib/googlecloudsdk/api_lib/ml_engine/operations.pyr r s  g ..c,[R"SXS9$)Nr )no_http)rGetClientInstance)r rs r rrs  g ??r c8^\rSrSrSrU4SjrSrSrSrU=r $)CloudMlOperationPoller"zPoller for Cloud ML Engine operations API. This is necessary because the core operations library doesn't directly support simple_uri. c>Xl[[U]URRRURRR5 gN)clientsuperr__init__projects_operations)selfr __class__s r rCloudMlOperationPoller.__init__)s>K $0 .. ..0r c8URRU5$r)rGetr operation_refs r PollCloudMlOperationPoller.Poll/s ;;??= ))r cU$r)r operations r GetResult CloudMlOperationPoller.GetResult2s r )r) __name__ __module__ __qualname____firstlineno____doc__rr!r&__static_attributes__ __classcell__)rs@r rr"s 0 *r rc>\rSrSrSrS SjrSrSrSrS Sjr S r g) OperationsClient6z9Client for operations service in the Cloud ML Engine API.cZ[U5UlURRUlgr)rrMESSAGES_MODULEmessages)rr s r rOperationsClient.__init__9s#G,DKKK//DMr c[R"URRURR UR 5S9SSS9$)Nname operationspageSize)fieldbatch_size_attribute)r YieldFromListrrr4MlProjectsOperationsListRequest RelativeName)r project_refs r ListOperationsClient.List=sK  # # '' 55))+ 6 -'  ))r cURRRURR UR 5S95$Nr7)rrrr4MlProjectsOperationsGetRequestr?rs r rOperationsClient.GetEsB ;; * * . . 44++- 5 / 00r cURRRURR UR 5S95$rD)rrCancelr4!MlProjectsOperationsCancelRequestr?rs r rHOperationsClient.CancelJsB ;; * * 1 1 77++- 8 / 00r Nc p[U5nURU5(aU$[RR UR S[ RRRR0SS9nUcSRUR55n[R"X4USSSSSSS 9 $) aZWait until the operation is complete or times out. Args: operation: The operation resource to wait on message: str, the message to print while waiting. Returns: The operation resource when it has completed Raises: OperationTimeoutError: when the operation polling times out OperationError: when the operation completed with an error projectsIdzml.projects.operations)params collectionNzWaiting for operation [{}]ri6i)pre_start_sleep_ms max_wait_msexponential_sleep_multiplier jitter_mswait_ceiling_mssleep_ms)rIsDonerREGISTRYParser8rVALUEScoreproject GetOrFailformatNamerWaitFor)rr%messagepollerr s r WaitForOperation!OperationsClient.WaitForOperationOs$D )F }}Y &&,,j//44<<FFG+--M,33M4F4F4HIg >>w%) r )rr4v1r) r(r)r*r+r,rrArrHrar-r$r r r0r06sA0)0 0 r r0Nrc)rdF)r,apitools.base.pyrgooglecloudsdk.api_lib.utilrrgooglecloudsdk.corerrr rCloudOperationPollerrobjectr0r$r r rjsEG(,.*)/@V88(8v8r