CSrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J r SSK J r S r S rS rS rSSjrSSjrSSjrg )z3A library used to interact with Operations objects.)absolute_import)division)unicode_literals) exceptions)progress_tracker)encoding)retryi`iicvSRUR[R"UR55$)zReturns a human readable string representation from the operation. Args: error: A string representing the raw json of the operation error. Returns: A human readable string representation of the error. z%OperationError: code={0}, message={1})formatcoderDecodemessage)errors 5lib/googlecloudsdk/api_lib/functions/v1/operations.pyOperationErrorToStringr s- 1 7 7 jj(//%--0 Nc>U(aU"5 U(aUR5 URRU5nUR(a)[R "[ UR55eU(aUH nU"U5 M UR$)aHelper function for getting the status of an operation. Args: client: The client used to make requests. get_request: A GetOperationRequest message. progress_tracker: progress_tracker.ProgressTracker, A reference for the progress tracker to tick, in case this function is used in a Retryer. try_set_invoker: function to try setting invoker, see above TODO. on_every_poll: list of functions to execute every time we poll. Functions should take in Operation as an argument. Returns: True if the operation succeeded without error. False if the operation is not yet done. Raises: FunctionsError: If the operation is finished with error. )Tick operationsGetrrFunctionsErrorrdone)client get_requestrtry_set_invoker on_every_pollopfunctions r_GetOperationStatusr/sq2 [)"XX  # #$:288$D EE!rl" .rc r[R"USS9n[R"S[[ S9nUR [X/UUUS.S[S9 S S S 5 g ![Ra0 [R"SRUR55ef=f!,(df  g =f) aWait for an operation to complete. No operation is done instantly. Wait for it to finish following this logic: * we wait 1s (jitter is also 1s) * we query service * if the operation is not finished we loop to first point * wait limit is 1820s - if we get to that point it means something is wrong and we can throw an exception Args: client: The client used to make requests. get_request: A GetOperationRequest message. message: str, The string to print while polling. try_set_invoker: function to try setting invoker, see above TODO. on_every_poll: list of functions to execute every time we poll. Functions should take in Operation as an argument. Returns: True if the operation succeeded without error. Raises: FunctionsError: If the operation takes more than 1820s. F)autotick)exponential_sleep_multiplier max_wait_mswait_ceiling_ms)rrrcU(+$)N)r_s r#_WaitForOperation..sd(r)should_retry_ifsleep_msz Operation {0} is taking too longN)console_progress_trackerProgressTrackerr Retryer MAX_WAIT_MSWAIT_CEILING_MS RetryOnResultrSLEEP_MS WaitExceptionrrr name)rrrrrptretryers r_WaitForOperationr8Vs6 //%HBmm%&'G     "$!0, 3 IH&     % % , 3 3K4D4D E 'IHsB(!A!!AB%%B(( B6cjUcSnUR5nURUl[X&X4U5 g)a<Initialize waiting for operation to finish. Generate get request based on the operation and wait for an operation to complete. Args: operation: The operation which we are waiting for. messages: GCF messages module. client: GCF client module. notice: str, displayed when waiting for the operation to finish. try_set_invoker: function to try setting invoker, see above TODO. on_every_poll: list of functions to execute every time we poll. Functions should take in Operation as an argument. Raises: FunctionsError: If the operation takes more than 620s. NzWaiting for operation to finish)"CloudfunctionsOperationsGetRequestr5r8) operationmessagesrnoticerrrequests rWaitr?s32 ^ .F  7 7 9'',FVmLr)NNN)NN)__doc__ __future__rrr#googlecloudsdk.api_lib.functions.v1rgooglecloudsdk.core.consolerr-googlecloudsdk.core.utilrr r0r1r3rrr8r?r'rrrEsd:'':T-*   $ #PGK1p  Mr