Y)SrSSKrSSKrSSKJr SSKJr SSKJr SSK J r SSK r Sr "SS \R5r"S S \R5r"S S \R5r"SS\ R""\R$\55r"SS\5r"SS\5rSSjrSSjrSrg)z-Utilities to support long running operations.N)encoding) exceptions)progress_tracker)retryzThe operations may still be underway remotely and may still succeed; use gcloud list and describe commands or https://console.developers.google.com/ to check resource state.c\rSrSrSrg) TimeoutError#N__name__ __module__ __qualname____firstlineno____static_attributes__r )lib/googlecloudsdk/api_lib/util/waiter.pyrr#rrc\rSrSrSrg)AbortWaitError'r Nr r rrrr'rrrc\rSrSrSrg)OperationError+r Nr r rrrr+rrrc\rSrSrSr\R S5r\R S5r\R S5r Sr g)OperationPoller/aInterface for defining operation which can be polled and waited on. This construct manages operation_ref, operation and result abstract objects. Operation_ref is an identifier for operation which is a proxy for result object. OperationPoller has three responsibilities: 1. Given operation object determine if it is done. 2. Given operation_ref fetch operation object 3. Given operation object fetch result object cg)zGiven result of Poll determines if result is done. Args: operation: object representing operation returned by Poll method. Returns: Tr self operations rIsDoneOperationPoller.IsDone: rcg)zRetrieves operation given its reference. Args: operation_ref: str, some id for operation. Returns: object which represents operation. Nr )r operation_refs rPollOperationPoller.PollFr#rcg)zGiven operation message retrieves result it represents. Args: operation: object, representing operation returned by Poll method. Returns: some object created by given operation. Nr rs r GetResultOperationPoller.GetResultRs rr N) r r rr__doc__abcabstractmethodr!r&r)rr rrrr/sU    rrc0\rSrSrSrSrSrSrSrSr g) CloudOperationPoller^zhManages a longrunning Operations. See https://cloud.google.com/speech/reference/rpc/google.longrunning cXlX lg)aSets up poller for cloud operations. Args: result_service: apitools.base.py.base_api.BaseApiService, api service for retrieving created result of initiated operation. operation_service: apitools.base.py.base_api.BaseApiService, api service for retrieving information about ongoing operation. Note that result_service and operation_service Get request must have single attribute called 'name'. N)result_serviceoperation_service)rr2r3s r__init__CloudOperationPoller.__init__ds).rcUR(a1UR(a[URR5eggz Overrides.TFdoneerrorrmessagers rr!CloudOperationPoller.IsDones+~~ Y__4455  rcURRS5nURRU"UR5S95$zrOverrides. Args: operation_ref: googlecloudsdk.core.resources.Resource. Returns: fetched operation message. Getname)r3GetRequestTyper@ RelativeNamerr% request_types rr&CloudOperationPoller.Poll{sD))88?L  ! ! % %-4467 99rcURRS5n[R"UR5nURR U"USS95$)znOverrides. Args: operation: api_name_messages.Operation. Returns: result of result_service.Get request. r@rBrA)r2rCrMessageToPyValueresponser@)rr rF response_dicts rr)CloudOperationPoller.GetResultsQ&&55e:CloudOperationPollerNoResources.__init__..s 0@rN)r3get_name)rr3 get_name_funcs rr4(CloudOperationPollerNoResources.__init__s/!A&@DMrcUR(a1UR(a[URR5eggr7r8rs rr!&CloudOperationPollerNoResources.IsDoner=rcURRS5nURRU"URU5S95$r?)r3rCr@rWrEs rr&$CloudOperationPollerNoResources.PollsD))88?L  ! ! % %$-- 67 99rcUR$)zOverrides to get the response from the completed operation. Args: operation: api_name_messages.Operation. Returns: the 'response' field of the Operation. )rJrs rr))CloudOperationPollerNoResources.GetResults   r)rWr3rSrMr rrrOrOsB" 9 rrOc D^^SRU5n U(d[R"X,S9OUmU(a [U5 UU4Sjn [ XXgXU X5 nSSS5 URW5$!,(df  N=f![ R a# [SRXS-[55e[ RaQn[SRUURRS-URR[55eSnAff=f)aWaits for poller.Poll and displays pending operation spinner. Args: poller: OperationPoller, poller to use during retrials. operation_ref: object, passed to operation poller poll method. message: str, string to display for default progress_tracker. custom_tracker: ProgressTracker, progress_tracker to use for display. tracker_update_func: func(tracker, result, status), tracker update function. pre_start_sleep_ms: int, Time to wait before making first poll request. max_retrials: int, max number of retrials before raising RetryException. max_wait_ms: int, number of ms to wait before raising WaitException. exponential_sleep_multiplier: float, factor to use on subsequent retries. jitter_ms: int, random (up to the value) additional sleep between retries. wait_ceiling_ms: int, Maximum wait between retries. sleep_ms: int or iterable: for how long to wait between trials. Returns: poller.GetResult(operation). Raises: AbortWaitError: if ctrl-c was pressed. TimeoutError: if retryer has finished without being done. z!Aborting wait for operation {0}. )aborted_messagecH>T(a T"TX5 gTR5 grS)Tick)resultstatustrackertracker_update_funcs r _StatusUpdateWaitFor.._StatusUpdates  gv 6 ,,.rNz2Operation {0} has not finished in {1} seconds. {2}zIOperation {0} has not finished in {1} seconds after max {2} retrials. {3})formatrProgressTracker_SleepMs PollUntilDoner WaitExceptionr_TIMEOUT_MESSAGEMaxRetrialsExceptionstatetime_passed_msretrialr))pollerr%r;custom_trackerrgpre_start_sleep_ms max_retrials max_wait_msexponential_sleep_multiplier jitter_mswait_ceiling_mssleep_msrarhr erfs ` @rWaitForrsF9?? N/#  ) ) !/ 03: #$   &? #i 0>   ) $$? 0 0$   G <  d24D E GG  # ##  &  &&$.  " ###s6B)A4B4 B>BBA DA DDc ^[R"UUUUUUS9n U4Sjn U RTRU4U US9n U $)aeWaits for poller.Poll to complete. Note that this *does not* print nice messages to stderr for the user; most callers should use WaitFor instead for the best UX unless there's a good reason not to print. Args: poller: OperationPoller, poller to use during retrials. operation_ref: object, passed to operation poller poll method. max_retrials: int, max number of retrials before raising RetryException. max_wait_ms: int, number of ms to wait before raising WaitException. exponential_sleep_multiplier: float, factor to use on subsequent retries. jitter_ms: int, random (up to the value) additional sleep between retries. wait_ceiling_ms: int, Maximum wait between retries. sleep_ms: int or iterable: for how long to wait between trials. status_update: func(result, state) called right after each trial. Returns: The return value from poller.Poll. )rxryrzr{r|status_update_funcc0>TRU5(+$rS)r!)r unused_staterus r _IsNotDone!PollUntilDone.._IsNotDone<s}}Y' ''r)funcargsshould_retry_ifr})rRetryer RetryOnResultr&) rur%rxryrzr{r|r} status_updateretryerrr s ` rrnrns\: MM#?%&  ('(## ;;    $) rc6[R"US- 5 g)Nrj)timesleep) milisecondss rrmrmHs**[4  r) NNNrjN@wffffff?rj )NrrrjrrN)r+r,rapitools.base.pyrgooglecloudsdk.corergooglecloudsdk.core.consolergooglecloudsdk.core.utilrsixrpErrorrrrwith_metaclassABCMetaobjectrr/rOrrnrmr rrrs 4 %*8* F :##Z%%Z%%,c((f=,^5M?5Mp7o7x $#),"D%P $%/2 "( $.b!r