SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SS K J r SS jr SS jr"S S \ R5r"SS\5rg)z@Utilities for dealing with long-running operations (simple uri).)absolute_import)division)unicode_literals) 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)rrs rrr!s  g ??rc8^\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 rrCloudMlOperationPoller.__init__,s>K $0 .. ..0rc8URRU5$r)rGetr operation_refs rPollCloudMlOperationPoller.Poll2s ;;??= ))rcU$r)r operations r GetResult CloudMlOperationPoller.GetResult5s r)r) __name__ __module__ __qualname____firstlineno____doc__rr$r)__static_attributes__ __classcell__)rs@rrr%s 0 *rrc>\rSrSrSrS SjrSrSrSrS Sjr S r g) OperationsClient9z9Client for operations service in the Cloud ML Engine API.cZ[U5UlURRUlgr)rrMESSAGES_MODULEmessages)rrs rrOperationsClient.__init__<s#G,DKKK//DMrc[R"URRURR UR 5S9SSS9$)Nname operationspageSize)fieldbatch_size_attribute)r YieldFromListrrr7MlProjectsOperationsListRequest RelativeName)r project_refs rListOperationsClient.List@sK  # # '' 55))+ 6 -'  ))rcURRRURR UR 5S95$Nr:)rrr!r7MlProjectsOperationsGetRequestrBr"s rr!OperationsClient.GetHsB ;; * * . . 44++- 5 / 00rcURRRURR UR 5S95$rG)rrCancelr7!MlProjectsOperationsCancelRequestrBr"s rrKOperationsClient.CancelMsB ;; * * 1 1 77++- 8 / 00rNc 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)rIsDoner REGISTRYParser;r VALUEScoreproject GetOrFailformatNamerWaitFor)rr(messagepollerr#s rWaitForOperation!OperationsClient.WaitForOperationRs$D )F }}Y &&,,j//44<<FFG+--M,33M4F4F4HIg >>w%) r)rr7v1r) r+r,r-r.r/rrDr!rKrdr0r'rrr3r39sA0)0 0 rr3Nrf)rgF)r/ __future__rrrapitools.base.pyrgooglecloudsdk.api_lib.utilrrgooglecloudsdk.corer r r rCloudOperationPollerrobjectr3r'rrrnsLG&'',.*)/@V88(8v8r