CdZddlmZddlmZddlmZddlmZddlmZ ddl m Z ddl m Z d Z d Zd Zd Z ddZ ddZ ddZy )z3A library used to interact with Operations objects.)absolute_import)division)unicode_literals) exceptions)progress_tracker)encoding)retryi`iictdj|jtj|jS)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|r||r|j|jj|}|jr(t j t |j|r|D] }|| |jS)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 ttj|d5}tjdtt } |j t||g|||ddt d d d y #tj$r/tjdj|jwxYw#1swYy xYw) aBWait 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)rrrc| S)N)r_s rz#_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_WaitForOperationr7Vs6 //%HBmm%&'G    ; "$!0, 3 IH&     % % , 3 3K4D4D E 'IHs!B.%A))AB++B..B7cl|d}|j}|j|_t|||||y)aVInitialize 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)"CloudfunctionsOperationsGetRequestr4r7) operationmessagesrnoticerrrequests rWaitr>s72 ^ .F  7 7 9'',FGV_mLr)NNN)NN)__doc__ __future__rrr#googlecloudsdk.api_lib.functions.v1rgooglecloudsdk.core.consolerr,googlecloudsdk.core.utilrr r/r0r2rrr7r>r'rrrDsd:'':T-*   $ #PGK1p  Mr