dZddlmZddlmZddlmZddlmZddlmZddlm Z ddlm Z dd lm Z d Z d Zdd ZddZGddej"ZGddeZy )z"Utilities for the clouddeploy API.)absolute_import)division)unicode_literals)apis)waiter) exceptions)log) resources clouddeployv1Nc6|xs t}|jS)zReturns the messages module for Cloud Deploy. Args: client: base_api.BaseApiClient, the client class for Cloud Deploy. Returns: Module containing the definitions of messages for Cloud Deploy. )GetClientInstanceMESSAGES_MODULE)clients 5lib/googlecloudsdk/api_lib/clouddeploy/client_util.pyGetMessagesModulers  (&(&   cDtjtt| S)zReturns an instance of the Cloud Deploy client. Args: use_http: bool, True to create an http object for this client. Returns: base_api.BaseApiClient, An instance of the Cloud Deploy client. )no_http)rr _API_NAME _API_VERSION)use_https rrr,s    >&- 99rc|jD]\}}|r |js tjj |jd}|j ||dj |j}tjj|j |y#tj$r8}tjjdj |Yd}~d}~wwxYw)a^Checks operations status. Only logs the errors instead of re-throwing them. Args: operation_dict: dict[str, oOptional[clouddeploy_messages.Operation], dictionary of resource name and clouddeploy_messages.Operation. The operation can be None if the operation isn't executed. msg_template: output string template. z)clouddeploy.projects.locations.operations) collectionz(Waiting for the operation on resource {}zOperation failed: {}N) itemsr5r REGISTRYParseRelativeNamer?r:responser statusPrintcore_exceptionsError)roperation_dict msg_template resource_namer)r%_es rCheckOperationStatusz%OperationsClient.CheckOperationStatus{s%3$8$8$: y inn ;!**<< NNB=D   ! ! } 6 = =  !) ,,];<%; " "; /66q9::;sBB//C:.C55C:)NNr")r+r,r-r.rr#r?rOr(rrr1r1QsB<0 :0;rr1r")T)r. __future__rrrgooglecloudsdk.api_lib.utilrrgooglecloudsdk.corerrHr r rrrrCloudOperationPollerrobjectr1r(rrrUsW)&',.=#)      QF772D;vD;r