)SrSSKJr SSKJr SSKJr SSKrSSKrSSKJr SSK J r SSK J r SS K Jr SSKrS r"S S \ R"5r"S S\ R"5r"SS\ R"5r"SS\R*"\R,\55r"SS\5r"SS\5rSSjrSSjrSrg)z-Utilities to support long running operations.)absolute_import)division)unicode_literalsN)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.pyr r &rr c\rSrSrSrg)AbortWaitError*r Nrr rrrr*rrrc\rSrSrSrg)OperationError.r Nrr rrrr.rrrc\rSrSrSr\R S5r\R S5r\R S5r Sr g)OperationPoller2aInterface 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.PollIr&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 r!s r GetResultOperationPoller.GetResultUs rr N) rrrr__doc__abcabstractmethodr$r)r,rr rrrr2sU    rrc0\rSrSrSrSrSrSrSrSr g) CloudOperationPollerazhManages 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)r"r5r6s r__init__CloudOperationPoller.__init__gs).rcUR(a1UR(a[URR5eggz Overrides.TFdoneerrorrmessager!s rr$CloudOperationPoller.IsDonev+~~ Y__4455  rcURRS5nURRU"UR5S95$zrOverrides. Args: operation_ref: googlecloudsdk.core.resources.Resource. Returns: fetched operation message. Getname)r6GetRequestTyperC RelativeNamer"r( 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. rCrErD)r5rFrMessageToPyValueresponserC)r"r#rI response_dicts rr,CloudOperationPoller.GetResultsQ&&55e:CloudOperationPollerNoResources.__init__..s 0@rN)r6get_name)r"r6 get_name_funcs rr7(CloudOperationPollerNoResources.__init__s/!A&@DMrcUR(a1UR(a[URR5eggr:r;r!s rr$&CloudOperationPollerNoResources.IsDoner@rcURRS5nURRU"URU5S95$rB)r6rFrCrZrHs 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. )rMr!s rr,)CloudOperationPollerNoResources.GetResults   r)rZr6rVrPr rrrRrRsB" 9 rrRc 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 grV)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_trackerrjpre_start_sleep_ms max_retrials max_wait_msexponential_sleep_multiplier jitter_mswait_ceiling_mssleep_msrdrkr#eris ` @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. )r{r|r}r~rstatus_update_funcc0>TRU5(+$rV)r$)r# unused_staterxs r _IsNotDone!PollUntilDone.._IsNotDone?s}}Y' ''r)funcargsshould_retry_ifr)r Retryer RetryOnResultr)) rxr(r{r|r}r~rr status_updateretryerrr#s ` rrqrqs\: MM#?%&  ('(## ;;    $) rc6[R"US- 5 g)Nrm)timesleep) milisecondss rrprpKs**[4  r) NNNrmN@wffffff?rm )NrrrmrrN)r. __future__rrrr/rapitools.base.pyrgooglecloudsdk.corergooglecloudsdk.core.consolergooglecloudsdk.core.utilr sixrsErrorr rrwith_metaclassABCMetaobjectrr2rRrrqrpr rrrs 4&' %*8* F :##Z%%Z%%,c((f=,^5M?5Mp7o7x $#),"D%P $%/2 "( $.b!r