}dZddlmZddlmZddlmZddlZddlZddlmZddl m Z ddl m Z dd l m Z dd lmZdd lmZddlZd Zd Z ddZy)z%Base functions for DM write commands.)absolute_import)division)unicode_literalsN) exceptions)dm_util)log) properties)progress_tracker)resource_printerc||}|sz|j|jdtjjj j id}t|||j|j|j }||||r.tjdj|j|S)aExecutes the request, managing asynchronous behavior. Args: client: The API client to use. messages: The API message to use. resources: The API resource to use. request: The request to pass call. is_async: False if this call should poll for the Operation's success. call: Function that calls the appropriate API. logger: The log function to use for the operation. Should take the request and a boolean arg for async. Returns: The API response, probably an operation. Raises: HttpException: An http error response was received while executing api request. ToolException: Call encountered an error. projectzdeploymentmanager.operations)params collection)r zOperation [{0}] running....) Parsenamer VALUEScorer GetOrFailWaitForOperation operation operationTyperPrintformat) clientmessages resourcesrequestis_asynccallloggerresponse operation_refs =lib/googlecloudsdk/command_lib/deployment_manager/dm_write.pyExecuter$"s*']( OO :,,1199CCD1$3M  !H ( II+228==AB /cztj}tj|d||j S)zReturns a ready-to-print string representation from the operation error. Args: error: operation error object Returns: A ready-to-print string representation of the error. yaml)out)ioStringIOr rgetvalue)error error_messages r#GetOperationErrorr.Ks0++--M:    !!r%c d}d}dj|r|dznd|}|j||} tj|d5} ||kr|jj | } | j |jjjk(rY| jrBtjd j|tj| j| cd d d S||z }| jt!j"|||krtj$d j|t'j(|#1swYy xYw) aWait for an operation to complete. Polls the operation requested approximately every second, showing a progress indicator. Returns when the operation has completed. Args: client: The API client to use. messages: The API message to use. operation_name: The name of the operation to wait on, as returned by operations.list. operation_description: A short description of the operation to wait on, such as 'create' or 'delete'. Will be displayed to the user. project: The name of the project that this operation belongs to. timeout: Number of seconds to wait for. Defaults to 3 minutes. Returns: The operation when it is done. Raises: HttpException: A http error response was received while executing api request. Will be raised if the operation cannot be found. OperationError: The operation finished with error(s). Error: The operation the timeout without completing. rzWaiting for {0}[{1}] )r rF)autotickzError in Operation [{0}]: {1}Nz0Wait for Operation [{0}] exceeded timeout [{1}].)r%DeploymentmanagerOperationsGetRequestr ProgressTracker operationsGetstatus OperationStatusValueValuesEnumDONEr,rOperationErrorrRenderMessageAsYamlTicktimesleepErrorsix text_type) rroperation_nameoperation_descriptionr timeouttick_incrementticksmessagertickerrs r#rrYsK6. % # * *%:c!'  : : ; 1'''%@F '/##''0i   X//EEJJ J ??))-44 '"="=ioo"NPQ QA@ ~e kkm jj  '/   :AA CMM'2 4 55#A@sBE//E8EE )NN)__doc__ __future__rrrr)r?)googlecloudsdk.api_lib.deployment_managerr-googlecloudsdk.command_lib.deployment_managerrgooglecloudsdk.corerr googlecloudsdk.core.consoler googlecloudsdk.core.resourcer rBr$r.rr%r#rTsF ,&' @A#*89 &R ",0+.55r%